public class ProtonConsumer extends Object implements ProtonDeliveryHandler
Constructor and Description |
---|
ProtonConsumer(ProtonRemotingConnection connection,
org.apache.qpid.proton.engine.Sender sender,
ProtonSession protonSession,
HornetQServer server,
ProtonProtocolManager protonProtocolManager) |
Modifier and Type | Method and Description |
---|---|
void |
checkState() |
void |
close() |
long |
getConsumerID() |
org.apache.qpid.proton.engine.Sender |
getSender() |
int |
handleDelivery(ServerMessage message,
int deliveryCount) |
void |
init() |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
start() |
public ProtonConsumer(ProtonRemotingConnection connection, org.apache.qpid.proton.engine.Sender sender, ProtonSession protonSession, HornetQServer server, ProtonProtocolManager protonProtocolManager)
public void start() throws HornetQAMQPException
HornetQAMQPException
public void init() throws HornetQAMQPException
HornetQAMQPException
public void close() throws HornetQAMQPException
close
in interface ProtonDeliveryHandler
HornetQAMQPException
public long getConsumerID()
public int handleDelivery(ServerMessage message, int deliveryCount)
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws HornetQAMQPException
onMessage
in interface ProtonDeliveryHandler
HornetQAMQPException
public void checkState()
checkState
in interface ProtonDeliveryHandler
public org.apache.qpid.proton.engine.Sender getSender()
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.