public class ProtonClientContext extends AbstractProtonContextSender implements AMQPClientSenderContext
closed, connection, creditsSemaphore, protonSession, sender, sessionSPI
Constructor and Description |
---|
ProtonClientContext(AbstractConnectionContext connection,
org.apache.qpid.proton.engine.Sender sender,
AbstractProtonSessionContext protonSession,
AMQPSessionCallback server) |
Modifier and Type | Method and Description |
---|---|
String |
getAddress() |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
send(org.apache.qpid.proton.message.ProtonJMessage message) |
boolean |
sync(long timeout,
TimeUnit unit) |
checkState, close, close, getSender, onFlow, performSend, start
afterInit, initialise, isInitialized, waitWithTimeout
public ProtonClientContext(AbstractConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AbstractProtonSessionContext protonSession, AMQPSessionCallback server)
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws ActiveMQAMQPException
onMessage
in interface ProtonDeliveryHandler
onMessage
in class AbstractProtonContextSender
ActiveMQAMQPException
public void send(org.apache.qpid.proton.message.ProtonJMessage message)
send
in interface AMQPClientSenderContext
public boolean sync(long timeout, TimeUnit unit)
public String getAddress()
getAddress
in interface AMQPClientSenderContext
Copyright © 2016 The Apache Software Foundation. All rights reserved.