public final class OSCPConsumer extends org.yads.java.client.DefaultClient implements OSCPEndpoint
| Modifier and Type | Field and Description |
|---|---|
protected java.lang.Object |
clientSubscriptionLock |
protected static int |
CYLCLE_RENEW |
protected static int |
DURATION_SUBSCRIPTION |
| Constructor and Description |
|---|
OSCPConsumer(org.yads.java.service.reference.DeviceReference deviceRef) |
| Modifier and Type | Method and Description |
|---|---|
InvocationState |
activate(java.lang.String handle,
FutureInvocationState fis) |
InvocationState |
commitState(State state,
FutureInvocationState fis) |
void |
disconnect() |
org.yads.java.service.parameter.ParameterValue |
eventReceived(org.yads.java.eventing.ClientSubscription subscription,
org.yads.java.types.URI actionURI,
org.yads.java.service.parameter.ParameterValue parameterValue) |
OSCPConnectionLostHandler |
getConnectionLostHandler() |
MDDescription |
getMDDescription()
Get deep clone of MD description.
|
MDIB |
getMDIB()
Create an MDIB container object.
|
MDState |
getMDState()
Get deep clone of all MD states.
|
MDState |
getMDState(java.util.List<java.lang.String> handles)
Get deep clone of MD states.
|
boolean |
isConnected() |
void |
registerEventHandler(OSCPConsumerHandler handler) |
State |
requestState(java.lang.String handle) |
void |
setConnectionLostHandler(OSCPConnectionLostHandler connectionLostHandler) |
void |
subscriptionEndReceived(org.yads.java.eventing.ClientSubscription subscription,
int subscriptionEndType) |
void |
subscriptionTimeoutReceived(org.yads.java.eventing.ClientSubscription subscription) |
void |
unregisterEventHandler(OSCPConsumerHandler handler) |
void |
unregisterEventHandler(java.lang.String desriptorHandle) |
protected void |
unregisterFutureInvocationstate(FutureInvocationState fis) |
addSupportedProtocolInfo, announceCommunicationBindingDestroyed1, announceCommunicationBindingDown1, announceCommunicationBindingUp1, announceDiscoveryBindingDestroyed1, announceDiscoveryBindingDown1, announceDiscoveryBindingUp1, announceNewCommunicationBindingAvailable1, announceNewDiscoveryBindingAvailable1, announceNewInterfaceAvailable1, announceNewOutgoingDiscoveryInfoAvailable1, announceOutgoingDiscoveryInfoDestroyed1, deviceBuiltUp, deviceBye, deviceChanged, deviceCommunicationErrorOrReset, deviceCompletelyDiscovered, deviceFound, deviceRunning, finishedSearching, generateEventSink, getCommunicationStructureListener, getDefaultOutgoingDiscoveryInfos, getDefaultOutgoingDiscoveryInfos, getDefaultOutgoingDiscoveryInfosAutoBinding, getDeviceReference, getDeviceReference, getDeviceReference, getDeviceReference, getDeviceReference, getDeviceReference, getDiscoveryAutoBindingsForHelloListening, getDiscoveryBindingsForHelloListening, getEventSink, getServiceReference, getServiceReference, getSupportedProtocolInfos, getSupportedProtocolInfos, hasDiscoveryAutoBindingsForHelloListening, hasDiscoveryBindingsForHelloListening, helloReceived, isInDiscoveryAutoBindingsForHelloListening, isInDiscoveryBindingsForHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerHelloListening, registerServiceListening, removeSupportedProtocolInfo, searchDevice, searchService, serviceChanged, serviceCreated, serviceDisposed, serviceFound, startedSearching, unregisterHelloListening, unregisterHelloListening, unregisterHelloListening, unregisterHelloListening, unregisterHelloListening, unregisterServiceListeningprotected static final int DURATION_SUBSCRIPTION
protected static final int CYLCLE_RENEW
protected final java.lang.Object clientSubscriptionLock
public OSCPConsumer(org.yads.java.service.reference.DeviceReference deviceRef)
public void disconnect()
public boolean isConnected()
public void subscriptionEndReceived(org.yads.java.eventing.ClientSubscription subscription,
int subscriptionEndType)
subscriptionEndReceived in interface org.yads.java.eventing.EventListenersubscriptionEndReceived in class org.yads.java.client.DefaultClientpublic void subscriptionTimeoutReceived(org.yads.java.eventing.ClientSubscription subscription)
subscriptionTimeoutReceived in interface org.yads.java.eventing.EventListenersubscriptionTimeoutReceived in class org.yads.java.client.DefaultClientpublic MDIB getMDIB()
OSCPEndpointgetMDIB in interface OSCPEndpointpublic MDDescription getMDDescription()
OSCPEndpointgetMDDescription in interface OSCPEndpointpublic MDState getMDState()
OSCPEndpointgetMDState in interface OSCPEndpointpublic MDState getMDState(java.util.List<java.lang.String> handles)
OSCPEndpointgetMDState in interface OSCPEndpointhandles - List of handles to match.public State requestState(java.lang.String handle)
public InvocationState activate(java.lang.String handle, FutureInvocationState fis)
public InvocationState commitState(State state, FutureInvocationState fis)
public void registerEventHandler(OSCPConsumerHandler handler)
public void unregisterEventHandler(OSCPConsumerHandler handler)
public void unregisterEventHandler(java.lang.String desriptorHandle)
public void setConnectionLostHandler(OSCPConnectionLostHandler connectionLostHandler)
public OSCPConnectionLostHandler getConnectionLostHandler()
public org.yads.java.service.parameter.ParameterValue eventReceived(org.yads.java.eventing.ClientSubscription subscription,
org.yads.java.types.URI actionURI,
org.yads.java.service.parameter.ParameterValue parameterValue)
eventReceived in interface org.yads.java.eventing.EventListenereventReceived in class org.yads.java.client.DefaultClientprotected void unregisterFutureInvocationstate(FutureInvocationState fis)