OpflowPubsubHandler (opflow-core 0.1.13 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()`
`int`	`getRedeliveredLimit()`
`String`	`getSubscriberName()`
`void`	`publish(byte[] body)`
`void`	`publish(byte[] body, Map<String,Object> options)`
`void`	`publish(byte[] body, Map<String,Object> options, String routingKey)`
`void`	`publish(String body)`
`void`	`publish(String body, Map<String,Object> opts)`
`void`	`publish(String body, Map<String,Object> opts, String routingKey)`
`OpflowEngine.ConsumerInfo`	`subscribe(OpflowPubsubListener newListener)`

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

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

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

public void publish(byte[] body,
                    Map<String,Object> options)

public void publish(byte[] body,
                    Map<String,Object> options,
                    String routingKey)

public OpflowEngine.ConsumerInfo subscribe(OpflowPubsubListener newListener)

public OpflowPubsubHandler.State check()

Class OpflowPubsubHandler