public class ProtonPublisherWrapperImpl extends Object implements ProtonPublisher<org.apache.qpid.proton.message.Message>
| Constructor and Description |
|---|
ProtonPublisherWrapperImpl(ProtonPublisherImpl delegate) |
| Modifier and Type | Method and Description |
|---|---|
ProtonReceiver |
getLink() |
String |
getRemoteAddress()
Retrieves the address from the remote source details.
|
org.apache.qpid.proton.amqp.transport.Source |
getRemoteSource()
Retrieves the remote Source details.
|
org.apache.qpid.proton.amqp.transport.Target |
getRemoteTarget()
Retrieves the remote Target details.
|
org.apache.qpid.proton.amqp.transport.Source |
getSource()
Retrieves the local Source details for access or customisation.
|
org.apache.qpid.proton.amqp.transport.Target |
getTarget()
Retrieves the local Target details for access or customisation.
|
boolean |
isEmitOnConnectionEnd() |
void |
setEmitOnConnectionEnd(boolean emitOnConnectionEnd) |
ProtonPublisher<org.apache.qpid.proton.message.Message> |
setSource(org.apache.qpid.proton.amqp.transport.Source source)
Sets the local Source details.
|
ProtonPublisher<org.apache.qpid.proton.message.Message> |
setTarget(org.apache.qpid.proton.amqp.transport.Target target)
Sets the local Target details.
|
void |
subscribe(org.reactivestreams.Subscriber<? super org.apache.qpid.proton.message.Message> subscriber) |
public ProtonPublisherWrapperImpl(ProtonPublisherImpl delegate)
public void subscribe(org.reactivestreams.Subscriber<? super org.apache.qpid.proton.message.Message> subscriber)
subscribe in interface org.reactivestreams.Publisher<org.apache.qpid.proton.message.Message>public boolean isEmitOnConnectionEnd()
public void setEmitOnConnectionEnd(boolean emitOnConnectionEnd)
public ProtonReceiver getLink()
public String getRemoteAddress()
ProtonPublishergetRemoteAddress in interface ProtonPublisher<org.apache.qpid.proton.message.Message>public ProtonPublisher<org.apache.qpid.proton.message.Message> setSource(org.apache.qpid.proton.amqp.transport.Source source)
ProtonPublishersetSource in interface ProtonPublisher<org.apache.qpid.proton.message.Message>source - the sourcepublic org.apache.qpid.proton.amqp.transport.Source getSource()
ProtonPublishergetSource in interface ProtonPublisher<org.apache.qpid.proton.message.Message>public ProtonPublisher<org.apache.qpid.proton.message.Message> setTarget(org.apache.qpid.proton.amqp.transport.Target target)
ProtonPublishersetTarget in interface ProtonPublisher<org.apache.qpid.proton.message.Message>target - the targetpublic org.apache.qpid.proton.amqp.transport.Target getTarget()
ProtonPublishergetTarget in interface ProtonPublisher<org.apache.qpid.proton.message.Message>public org.apache.qpid.proton.amqp.transport.Source getRemoteSource()
ProtonPublishergetRemoteSource in interface ProtonPublisher<org.apache.qpid.proton.message.Message>public org.apache.qpid.proton.amqp.transport.Target getRemoteTarget()
ProtonPublishergetRemoteTarget in interface ProtonPublisher<org.apache.qpid.proton.message.Message>Copyright © 2020. All rights reserved.