Package com.espertech.esperio.amqp

Class AMQPToObjectCollectorContext

java.lang.Object

com.espertech.esperio.amqp.AMQPToObjectCollectorContext

public class AMQPToObjectCollectorContext
extends Object

Constructor Summary

Constructors

Constructor	Description
AMQPToObjectCollectorContext(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter, byte[] bytes, QueueingConsumer.Delivery delivery, com.espertech.esper.common.client.EventType outputEventType)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

AMQPToObjectCollectorContext

public AMQPToObjectCollectorContext(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter,
 byte[] bytes,
 QueueingConsumer.Delivery delivery,
 com.espertech.esper.common.client.EventType outputEventType)

Method Details

getBytes

public byte[] getBytes()

setBytes

public void setBytes(byte[] bytes)

getEmitter

public com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter getEmitter()

getDelivery

public QueueingConsumer.Delivery getDelivery()

setDelivery

public void setDelivery(QueueingConsumer.Delivery delivery)

getOutputEventType

public com.espertech.esper.common.client.EventType getOutputEventType()