Publisher (root 1.5.5 API)

All Known Implementing Classes:: EventPublisher

public interface Publisher<T,S extends Subscriber<T>>

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`publish(java.lang.String subscriptionId, java.util.Map<java.lang.String,java.lang.Object> params)`	Request `Publisher` to send data.
`void`	`subscribe(S s)`	Request `Publisher` to start streaming data.

- Method Detail
  - subscribe
```
void subscribe(S s)
```
    Request Publisher to start streaming data.
    This is a "factory method" and can be called multiple times, each time starting a new Subscription.
    Each Subscription will work for only a single Subscriber.
    A Subscriber should only subscribe once to a single Publisher.
    If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber.onError(java.lang.Throwable).
    
    Parameters:
    
    s - the Subscriber that will consume signals from this Publisher
  - publish
```
void publish(java.lang.String subscriptionId,
             java.util.Map<java.lang.String,java.lang.Object> params)
      throws java.io.IOException
```
    Request Publisher to send data.
    
    Parameters:
    
    subscriptionId - the identifier for Subscriber who will consume the event
    
    params - the data that needs to be sent to the Subscriber
    
    Throws:
    
    java.io.IOException - an exception is thrown if the params cannot be serialized