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