public class ProtonProducer extends Object implements ProtonDeliveryHandler
Constructor and Description |
---|
ProtonProducer(ProtonRemotingConnection connection,
ProtonSession protonSession,
ProtonProtocolManager protonProtocolManager,
org.apache.qpid.proton.engine.Receiver receiver) |
Modifier and Type | Method and Description |
---|---|
void |
checkState() |
void |
close() |
void |
init() |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
public ProtonProducer(ProtonRemotingConnection connection, ProtonSession protonSession, ProtonProtocolManager protonProtocolManager, org.apache.qpid.proton.engine.Receiver receiver)
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 void close() throws HornetQAMQPException
close
in interface ProtonDeliveryHandler
HornetQAMQPException
public void init() throws HornetQAMQPException
HornetQAMQPException
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.