OpflowPubsubHandler (opflow-core 0.3.0 API)

java.lang.Object

com.devebot.opflow.OpflowPubsubHandler

All Implemented Interfaces:: AutoCloseable

public class OpflowPubsubHandler
extends Object
implements AutoCloseable

Author:: drupalex

Nested Class Summary

Nested Classes

Modifier and Type Class Description

class OpflowPubsubHandler.State
Constructor Summary

Constructors

Constructor Description

OpflowPubsubHandler(Map<String,Object> params)

Method Summary

Modifier and Type	Method	Description
`OpflowPubsubHandler.State`	`check()`
`void`	`close()`
`String`	`getComponentId()`
`OpflowEngine`	`getEngine()`
`OpflowExecutor`	`getExecutor()`
`int`	`getPrefetchCount()`
`String`	`getRecyclebinName()`
`int`	`getRedeliveredLimit()`
`int`	`getSubscriberLimit()`
`String`	`getSubscriberName()`
`void`	`publish(byte[] body)`
`void`	`publish(byte[] body, Map<String,Object> headers)`
`void`	`publish(byte[] body, Map<String,Object> headers, String routingKey)`
`void`	`publish(String body)`
`void`	`publish(String body, Map<String,Object> opts)`
`void`	`publish(String body, Map<String,Object> opts, String routingKey)`
`void`	`serve()`
`OpflowEngine.ConsumerInfo`	`subscribe(OpflowPubsubListener newListener)`

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- OpflowPubsubHandler
  
  public OpflowPubsubHandler(Map<String,Object> params) throws OpflowBootstrapException
  
  Throws:
  
  OpflowBootstrapException
Method Details
- publish
  
  public void publish(String body)
- publish
  
  public void publish(String body, Map<String,Object> opts)
- publish
  
  public void publish(String body, Map<String,Object> opts, String routingKey)
- publish
  
  public void publish(byte[] body)
- publish
  
  public void publish(byte[] body, Map<String,Object> headers)
- publish
  
  public void publish(byte[] body, Map<String,Object> headers, String routingKey)
- subscribe
  
  public OpflowEngine.ConsumerInfo subscribe(OpflowPubsubListener newListener)
- serve
  
  public final void serve()
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable
- check
  
  public OpflowPubsubHandler.State check()
- getEngine
  
  public OpflowEngine getEngine()
- getExecutor
  
  public OpflowExecutor getExecutor()
- getComponentId
  
  public String getComponentId()
- getPrefetchCount
  
  public int getPrefetchCount()
- getSubscriberName
  
  public String getSubscriberName()
- getSubscriberLimit
  
  public int getSubscriberLimit()
- getRecyclebinName
  
  public String getRecyclebinName()
- getRedeliveredLimit
  
  public int getRedeliveredLimit()