public abstract class AbstractObservable extends Object implements Observable
Modifier and Type | Field and Description |
---|---|
protected MessageObserver |
incomingObserver |
Constructor and Description |
---|
AbstractObservable() |
Modifier and Type | Method and Description |
---|---|
protected void |
activate()
Activate messages flow.
|
protected void |
deactivate()
Deactivate messages flow.
|
protected abstract Logger |
getLogger() |
MessageObserver |
getMessageObserver()
Retrieves the message observer for incoming messages
|
protected static EndpointReferenceType |
getTargetReference(EndpointInfo ei,
Bus bus)
Get the target reference .
|
protected static EndpointReferenceType |
getTargetReference(EndpointInfo ei,
EndpointReferenceType t,
Bus bus)
Get the target endpoint reference.
|
void |
setMessageObserver(MessageObserver observer)
Register a message observer for incoming messages.
|
protected MessageObserver incomingObserver
public void setMessageObserver(MessageObserver observer)
setMessageObserver
in interface Observable
observer
- the observer to notify on receipt of incoming
messagepublic MessageObserver getMessageObserver()
Observable
getMessageObserver
in interface Observable
protected static EndpointReferenceType getTargetReference(EndpointInfo ei, Bus bus)
ei
- the corresponding EndpointInfoprotected static EndpointReferenceType getTargetReference(EndpointInfo ei, EndpointReferenceType t, Bus bus)
ei
- the corresponding EndpointInfot
- the given target EPR if availablebus
- the Busprotected void activate()
protected void deactivate()
protected abstract Logger getLogger()
Apache CXF