public class Connection extends SessionConnectionBase implements Connection
Modifier and Type | Class and Description |
---|---|
static class |
Connection.WriteAttributeOperationFuture |
static class |
Connection.WriteOperationFuture |
Modifier and Type | Field and Description |
---|---|
static String |
VERSION |
executor, SESSION_CLIENT_VERSION
messenger, session, statistics
Constructor and Description |
---|
Connection(ConnectionInformation connectionInformantion) |
addPrivilegeListener, dispose, getPrivileges, handlePrivChange, modifyFilterChain, onConnectionEstablished, processSessionReply, removePrivilegeListener, requestSession
addConnectionStateListener, cancelConnection, connect, connect, connectFailed, disconnect, disconnect, exceptionCaught, finalize, getConnectionInformation, getConnectTimeout, getIntProperty, getMessageTimeout, getPingPeriod, getSessionProperties, getSocketReceiveBufferSize, getSocketSendBufferSize, getState, getStatistics, isConnected, messageReceived, messageSent, onConnectionBound, performConnect, performLookup, removeConnectionStateListener, resolvedRemoteAddress, sessionClosed, sessionCreated, sessionIdle, sessionOpened, setBound, setCallbackFactory, setupConnector, switchState
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addConnectionStateListener, addPrivilegeListener, connect, connect, disconnect, dispose, getConnectionInformation, getPrivileges, getSessionProperties, getState, removeConnectionStateListener, removePrivilegeListener, setCallbackFactory
public static final String VERSION
public Connection(ConnectionInformation connectionInformantion)
public String getRequiredVersion()
getRequiredVersion
in class SessionConnectionBase
public NotifyFuture<WriteResult> startWrite(String itemId, Variant value, OperationParameters operationParameters, CallbackHandler callbackHandler)
public void write(String item, Variant value, OperationParameters operationParameters, WriteOperationCallback callback)
protected void completeWrite(LongRunningOperation operation) throws OperationException
OperationException
public NotifyFuture<WriteAttributeResults> startWriteAttributes(String itemId, Map<String,Variant> attributes, OperationParameters operationParameters, CallbackHandler callbackHandler)
public void writeAttributes(String item, Map<String,Variant> attributes, OperationParameters operationParameters, WriteAttributeOperationCallback callback)
public WriteAttributeResults completeWriteAttributes(LongRunningOperation operation) throws OperationException
OperationException
protected Entry[] completeBrowse(LongRunningOperation operation) throws OperationException
OperationException
public void subscribeItem(String itemId) throws NoConnectionException
NoConnectionException
public void unsubscribeItem(String itemId) throws NoConnectionException
NoConnectionException
public ItemUpdateListener setItemUpdateListener(String itemId, ItemUpdateListener listener)
Connection
itemId
- The item for which to set the listenerlistener
- The listener to setnull
if there was no
previous listenerpublic FolderListener setFolderListener(Location location, FolderListener listener)
Connection
location
- The location for which to set the listenerlistener
- The listener to setnull
if there was no
previous listenerpublic void subscribeFolder(Location location) throws NoConnectionException, OperationException
public void unsubscribeFolder(Location location) throws NoConnectionException, OperationException
protected void onConnectionClosed()
onConnectionClosed
in class SessionConnectionBase
protected void performSubscriptionChange(Message message)
public Entry[] browse(Location location, int timeout) throws NoConnectionException, OperationException
public void browse(Location location, BrowseOperationCallback callback)
Connection
location
- The path to browsecallback
- The callback that shall receive notifications of the operationpublic ScheduledExecutorService getExecutor()
Connection
null