public class ProtonSubscriberWrapperImpl extends Object implements ProtonSubscriber<org.apache.qpid.proton.message.Message>
| Constructor and Description |
|---|
ProtonSubscriberWrapperImpl(ProtonSubscriberImpl delegate) |
| Modifier and Type | Method and Description |
|---|---|
ProtonSender |
getLink() |
org.apache.qpid.proton.amqp.transport.Source |
getRemoteSource() |
org.apache.qpid.proton.amqp.transport.Target |
getRemoteTarget() |
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 |
onComplete() |
void |
onError(Throwable t) |
void |
onNext(org.apache.qpid.proton.message.Message m) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
void |
setEmitOnConnectionEnd(boolean emitOnConnectionEnd) |
ProtonSubscriber<org.apache.qpid.proton.message.Message> |
setSource(org.apache.qpid.proton.amqp.transport.Source source)
Sets the local Source details.
|
ProtonSubscriber<org.apache.qpid.proton.message.Message> |
setTarget(org.apache.qpid.proton.amqp.transport.Target target)
Sets the local Target details.
|
public ProtonSubscriberWrapperImpl(ProtonSubscriberImpl delegate)
public void onSubscribe(org.reactivestreams.Subscription subscription)
onSubscribe in interface org.reactivestreams.Subscriber<org.apache.qpid.proton.message.Message>public void onNext(org.apache.qpid.proton.message.Message m)
onNext in interface org.reactivestreams.Subscriber<org.apache.qpid.proton.message.Message>public void onError(Throwable t)
onError in interface org.reactivestreams.Subscriber<org.apache.qpid.proton.message.Message>public void onComplete()
onComplete in interface org.reactivestreams.Subscriber<org.apache.qpid.proton.message.Message>public boolean isEmitOnConnectionEnd()
public void setEmitOnConnectionEnd(boolean emitOnConnectionEnd)
public ProtonSender getLink()
public ProtonSubscriber<org.apache.qpid.proton.message.Message> setSource(org.apache.qpid.proton.amqp.transport.Source source)
ProtonSubscribersetSource in interface ProtonSubscriber<org.apache.qpid.proton.message.Message>source - the sourcepublic org.apache.qpid.proton.amqp.transport.Source getSource()
ProtonSubscribergetSource in interface ProtonSubscriber<org.apache.qpid.proton.message.Message>public ProtonSubscriber<org.apache.qpid.proton.message.Message> setTarget(org.apache.qpid.proton.amqp.transport.Target target)
ProtonSubscribersetTarget in interface ProtonSubscriber<org.apache.qpid.proton.message.Message>target - the targetpublic org.apache.qpid.proton.amqp.transport.Target getTarget()
ProtonSubscribergetTarget in interface ProtonSubscriber<org.apache.qpid.proton.message.Message>public org.apache.qpid.proton.amqp.transport.Source getRemoteSource()
public org.apache.qpid.proton.amqp.transport.Target getRemoteTarget()
Copyright © 2020. All rights reserved.