OpflowPubsubHandler (opflow-core 0.1.7 API)

public class OpflowPubsubHandler
extends Object

Nested Classes
Modifier and Type	Class and Description
`class`	`OpflowPubsubHandler.State`

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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`OpflowPubsubHandler.State`	`check()`
`void`	`close()`
`OpflowExecutor`	`getExecutor()`
`String`	`getRecyclebinName()`
`String`	`getSubscriberName()`
`void`	`publish(byte[] data)`
`void`	`publish(byte[] data, Map<String,Object> opts)`
`void`	`publish(byte[] data, Map<String,Object> opts, String routingKey)`
`void`	`publish(String data)`
`void`	`publish(String data, Map<String,Object> opts)`
`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)

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

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

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

public OpflowBroker.ConsumerInfo subscribe(OpflowPubsubListener listener)

public OpflowPubsubHandler.State check()

Class OpflowPubsubHandler