Package | Description |
---|---|
org.hornetq.core.protocol.proton |
Modifier and Type | Method and Description |
---|---|
ProtonSession |
ProtonProtocolManager.createSession(ProtonRemotingConnection protonConnection,
org.apache.qpid.proton.engine.impl.TransportImpl protonTransport) |
void |
ProtonProtocolManager.handleDelivery(org.apache.qpid.proton.engine.Sender sender,
byte[] tag,
org.apache.qpid.proton.jms.EncodedMessage encodedMessage,
ServerMessage message,
ProtonRemotingConnection connection,
boolean preSettle) |
void |
ProtonProtocolManager.handleMessage(org.apache.qpid.proton.engine.Receiver receiver,
HornetQBuffer buffer,
org.apache.qpid.proton.engine.Delivery delivery,
ProtonRemotingConnection connection,
ProtonSession protonSession,
String address) |
static ServerMessageImpl |
ProtonUtils.INBOUND.transform(ProtonRemotingConnection connection,
org.apache.qpid.proton.jms.EncodedMessage encodedMessage) |
Constructor and Description |
---|
ProtonConsumer(ProtonRemotingConnection connection,
org.apache.qpid.proton.engine.Sender sender,
ProtonSession protonSession,
HornetQServer server,
ProtonProtocolManager protonProtocolManager) |
ProtonProducer(ProtonRemotingConnection connection,
ProtonSession protonSession,
ProtonProtocolManager protonProtocolManager,
org.apache.qpid.proton.engine.Receiver receiver) |
ProtonSession(String name,
ProtonRemotingConnection connection,
ProtonProtocolManager protonProtocolManager,
OperationContext operationContext,
HornetQServer server,
org.apache.qpid.proton.engine.impl.TransportImpl protonTransport) |
TransactionHandler(ProtonRemotingConnection connection,
org.apache.qpid.proton.amqp.transaction.Coordinator coordinator,
ProtonProtocolManager protonProtocolManager,
ProtonSession protonSession) |
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.