OpflowPubsubHandler (opflow-core 0.1.4 API)

public class OpflowPubsubHandler
extends Object

Constructors
Constructor and Description
`OpflowPubsubHandler(Map<String,Object> params)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`publish(byte[] data, Map<String,Object> opts, String routingKey)`
`void`	`publish(String data, Map<String,Object> opts, String routingKey)`
`OpflowBroker.ConsumerInfo`	`subscribe(OpflowPubsubListener listener)`

public OpflowPubsubHandler(Map<String,Object> params)
                    throws OpflowConstructorException

public void publish(String data,
                    Map<String,Object> opts,
                    String routingKey)

public void publish(byte[] data,
                    Map<String,Object> opts,
                    String routingKey)

public OpflowBroker.ConsumerInfo subscribe(OpflowPubsubListener listener)

Class OpflowPubsubHandler