public interface PubSubConfigurator
NodeId onAddConnection(PublishSubscribeTypeNode publishSubscribeTypeNode, ServiceContext serviceContext, PubSubConnectionDataType configuration) throws StatusException
StatusExceptionNodeId onAddDataSetFolder(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, String name) throws StatusException
StatusExceptionNodeId onAddDataSetReader(ReaderGroupTypeNode readerGroupTypeNode, ServiceContext serviceContext, DataSetReaderDataType configuration) throws StatusException
StatusExceptionNodeId onAddDataSetWriter(WriterGroupTypeNode writerGroupTypeNode, ServiceContext serviceContext, DataSetWriterDataType configuration) throws StatusException
StatusExceptionNodeId onAddExtensionField(ExtensionFieldsTypeNode extensionFieldsTypeNode, ServiceContext serviceContext, QualifiedName fieldName, Object fieldValue) throws StatusException
StatusExceptionDataSetFolderType.AddPublishedDataItemsMethodOutputs onAddPublishedDataItems(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, String name, String[] fieldNameAliases, DataSetFieldFlags[] fieldFlags, PublishedVariableDataType[] variablesToAdd) throws StatusException
StatusExceptionDataSetFolderType.AddPublishedDataItemsTemplateMethodOutputs onAddPublishedDataItemsTemplate(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, String name, DataSetMetaDataType dataSetMetaData, PublishedVariableDataType[] variablesToAdd) throws StatusException
StatusExceptionDataSetFolderType.AddPublishedEventsMethodOutputs onAddPublishedEvents(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, String name, NodeId eventNotifier, String[] fieldNameAliases, DataSetFieldFlags[] fieldFlags, SimpleAttributeOperand[] selectedFields, ContentFilter filter) throws StatusException
StatusExceptionNodeId onAddPublishedEventsTemplate(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, String name, DataSetMetaDataType dataSetMetaData, NodeId eventNotifier, SimpleAttributeOperand[] selectedFields, ContentFilter filter) throws StatusException
StatusExceptionNodeId onAddReaderGroup(PubSubConnectionTypeNode pubSubConnectionTypeNode, ServiceContext serviceContext, ReaderGroupDataType configuration) throws StatusException
StatusExceptionStatusCode[] onAddTargetVariables(TargetVariablesTypeNode targetVariablesTypeNode, ServiceContext serviceContext, ConfigurationVersionDataType configurationVersion, FieldTargetDataType[] targetVariablesToAdd) throws StatusException
StatusExceptionPublishedDataItemsType.AddVariablesMethodOutputs onAddVariables(PublishedDataItemsTypeNode publishedDataItemsTypeNode, ServiceContext serviceContext, ConfigurationVersionDataType configurationVersion, String[] fieldNameAliases, Boolean[] promotedFields, PublishedVariableDataType[] variablesToAdd) throws StatusException
StatusExceptionNodeId onAddWriterGroup(PubSubConnectionTypeNode pubSubConnectionTypeNode, ServiceContext serviceContext, WriterGroupDataType configuration) throws StatusException
StatusExceptionNodeId onCreateDataSetMirror(DataSetReaderTypeNode dataSetReaderTypeNode, ServiceContext serviceContext, String parentNodeName, RolePermissionType[] rolePermissions) throws StatusException
StatusExceptionStatusCode[] onCreateTargetVariables(DataSetReaderTypeNode dataSetReaderTypeNode, ServiceContext serviceContext, ConfigurationVersionDataType configurationVersion, FieldTargetDataType[] targetVariablesToAdd) throws StatusException
StatusExceptionvoid onDisable(PubSubStatusTypeNode pubSubStatusTypeNode, ServiceContext serviceContext) throws StatusException
StatusExceptionvoid onEnable(PubSubStatusTypeNode pubSubStatusTypeNode, ServiceContext serviceContext) throws StatusException
StatusExceptionNodeId onGetSecurityGroup(PubSubKeyServiceTypeNode pubSubKeyServiceTypeNode, ServiceContext serviceContext, String securityGroupId) throws StatusException
StatusExceptionPubSubKeyServiceType.GetSecurityKeysMethodOutputs onGetSecurityKeys(PubSubKeyServiceTypeNode pubSubKeyServiceTypeNode, ServiceContext serviceContext, String securityGroupId, UnsignedInteger startingTokenId, UnsignedInteger requestedKeyCount) throws StatusException
StatusExceptionConfigurationVersionDataType onModifyFieldSelection(PublishedEventsTypeNode publishedEventsTypeNode, ServiceContext serviceContext, ConfigurationVersionDataType configurationVersion, String[] fieldNameAliases, Boolean[] promotedFields, SimpleAttributeOperand[] selectedFields) throws StatusException
StatusExceptionvoid onRemoveConnection(PublishSubscribeTypeNode publishSubscribeTypeNode, ServiceContext serviceContext, NodeId connectionId) throws StatusException
StatusExceptionvoid onRemoveDataSetFolder(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, NodeId dataSetFolderNodeId) throws StatusException
StatusExceptionvoid onRemoveDataSetReader(ReaderGroupTypeNode readerGroupTypeNode, ServiceContext serviceContext, NodeId dataSetReaderNodeId) throws StatusException
StatusExceptionvoid onRemoveDataSetWriter(WriterGroupTypeNode writerGroupTypeNode, ServiceContext serviceContext, NodeId dataSetWriterNodeId) throws StatusException
StatusExceptionvoid onRemoveExtensionField(ExtensionFieldsTypeNode extensionFieldsTypeNode, ServiceContext serviceContext, NodeId fieldId) throws StatusException
StatusExceptionvoid onRemoveGroup(PubSubConnectionTypeNode pubSubConnectionTypeNode, ServiceContext serviceContext, NodeId groupId) throws StatusException
StatusExceptionvoid onRemovePublishedDataSet(DataSetFolderTypeNode dataSetFolderTypeNode, ServiceContext serviceContext, NodeId dataSetNodeId) throws StatusException
StatusExceptionStatusCode[] onRemoveTargetVariables(TargetVariablesTypeNode targetVariablesTypeNode, ServiceContext serviceContext, ConfigurationVersionDataType configurationVersion, UnsignedInteger[] targetsToRemove) throws StatusException
StatusExceptionPublishedDataItemsType.RemoveVariablesMethodOutputs onRemoveVariables(PublishedDataItemsTypeNode publishedDataItemsTypeNode, ServiceContext serviceContext, ConfigurationVersionDataType configurationVersion, UnsignedInteger[] variablesToRemove) throws StatusException
StatusExceptionvoid onReset(PubSubDiagnosticsTypeNode pubSubDiagnosticsTypeNode, ServiceContext serviceContext) throws StatusException
StatusExceptionvoid onSetSecurityKeys(PublishSubscribeTypeNode publishSubscribeTypeNode, ServiceContext serviceContext, String securityGroupId, String securityPolicyUri, UnsignedInteger currentTokenId, ByteString currentKey, ByteString[] futureKeys, Double timeToNextKey, Double keyLifetime) throws StatusException
StatusExceptionCopyright © 2026. All rights reserved.