public class SubscriptionManager extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
SubscriptionManager.Worker<T> |
Constructor and Description |
---|
SubscriptionManager(MiloClientConfiguration configuration,
org.eclipse.milo.opcua.sdk.client.api.config.OpcUaClientConfigBuilder clientBuilder,
ScheduledExecutorService executor,
long reconnectTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
dispose() |
org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger |
registerItem(NamespaceId namespaceId,
PartialNodeId partialNodeId,
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) |
void |
write(NamespaceId namespaceId,
PartialNodeId partialNodeId,
org.eclipse.milo.opcua.stack.core.types.builtin.DataValue value,
boolean await) |
public SubscriptionManager(MiloClientConfiguration configuration, org.eclipse.milo.opcua.sdk.client.api.config.OpcUaClientConfigBuilder clientBuilder, 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(NamespaceId namespaceId, PartialNodeId partialNodeId, 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 void write(NamespaceId namespaceId, PartialNodeId partialNodeId, org.eclipse.milo.opcua.stack.core.types.builtin.DataValue value, boolean await)
Apache Camel