public class SubscriptionManager extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
SubscriptionManager.Worker<T> |
Constructor and Description |
---|
SubscriptionManager(MiloClientConfiguration configuration,
ScheduledExecutorService executor,
long reconnectTimeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CallMethodResult> |
call(org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId nodeId,
org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId methodId,
org.eclipse.milo.opcua.stack.core.types.builtin.Variant[] inputArguments) |
void |
dispose() |
org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger |
registerItem(org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId nodeId,
Double samplingInterval,
Consumer<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> valueConsumer) |
void |
unregisterItem(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger clientHandle) |
protected void |
whenConnected(SubscriptionManager.Worker<org.apache.camel.component.milo.client.internal.SubscriptionManager.Connected> worker) |
CompletableFuture<?> |
write(org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId nodeId,
org.eclipse.milo.opcua.stack.core.types.builtin.DataValue value) |
public SubscriptionManager(MiloClientConfiguration configuration, ScheduledExecutorService executor, long reconnectTimeout)
public void dispose()
protected void whenConnected(SubscriptionManager.Worker<org.apache.camel.component.milo.client.internal.SubscriptionManager.Connected> worker)
public org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger registerItem(org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId nodeId, Double samplingInterval, Consumer<org.eclipse.milo.opcua.stack.core.types.builtin.DataValue> valueConsumer)
public void unregisterItem(org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger clientHandle)
public CompletableFuture<org.eclipse.milo.opcua.stack.core.types.structured.CallMethodResult> call(org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId nodeId, org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId methodId, org.eclipse.milo.opcua.stack.core.types.builtin.Variant[] inputArguments)
public CompletableFuture<?> write(org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId nodeId, org.eclipse.milo.opcua.stack.core.types.builtin.DataValue value)
Apache Camel