com.espertech.esperio.amqp

Class AMQPToObjectCollectorContext

java.lang.Object

com.espertech.esperio.amqp.AMQPToObjectCollectorContext

public class AMQPToObjectCollectorContext
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
AMQPToObjectCollectorContext(com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter emitter, byte[] bytes, com.rabbitmq.client.QueueingConsumer.Delivery delivery)

Method Summary

Modifier and Type	Method and Description
byte[]	getBytes()
com.rabbitmq.client.QueueingConsumer.Delivery	getDelivery()
com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter	getEmitter()
void	setBytes(byte[] bytes)
void	setDelivery(com.rabbitmq.client.QueueingConsumer.Delivery delivery)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPToObjectCollectorContext

public AMQPToObjectCollectorContext(com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter emitter,
                                    byte[] bytes,
                                    com.rabbitmq.client.QueueingConsumer.Delivery delivery)

Method Detail

getBytes

public byte[] getBytes()

setBytes

public void setBytes(byte[] bytes)

getEmitter

public com.espertech.esper.dataflow.interfaces.EPDataFlowEmitter getEmitter()

getDelivery

public com.rabbitmq.client.QueueingConsumer.Delivery getDelivery()

setDelivery

public void setDelivery(com.rabbitmq.client.QueueingConsumer.Delivery delivery)