private org.apache.ws.notification.base.impl.NotificationProducerHelper m_producerHelper = new org.apache.ws.notification.base.impl.NotificationProducerHelper( this ); private org.apache.ws.notification.topics.TopicSet m_topicSet = new org.apache.ws.notification.topics.impl.TopicSetImpl(); public org.apache.ws.notification.topics.TopicSet getTopicSet() { return m_topicSet; } public void setTopicSet( org.apache.ws.notification.topics.TopicSet topicSet ) { m_topicSet = topicSet; } public void publish( org.apache.ws.notification.topics.expression.TopicExpression topicExpr, Object msg ) throws org.apache.ws.notification.topics.expression.InvalidTopicExpressionException, org.apache.ws.notification.base.impl.TopicNotSupportedException, org.apache.ws.notification.base.impl.MessageTypeNotSupportedException { m_producerHelper.publish( topicExpr, msg ); } public org.apache.ws.addressing.EndpointReference subscribe( org.apache.ws.addressing.EndpointReference consumerEPR, org.apache.ws.notification.topics.expression.TopicExpression topicExpr, Boolean useNotify, org.apache.ws.resource.properties.query.QueryExpression precondition, org.apache.ws.resource.properties.query.QueryExpression selector, Object subscriptionPolicy, java.util.Calendar initialTerminationtime ) throws org.apache.ws.notification.base.impl.SubscribeCreationFailedException, org.apache.ws.notification.topics.expression.TopicPathDialectUnknownException, org.apache.ws.notification.topics.expression.InvalidTopicExpressionException { return m_producerHelper.subscribe( consumerEPR, topicExpr, useNotify, precondition, selector, subscriptionPolicy, initialTerminationtime ); } public Object getCurrentMessage( org.apache.ws.notification.topics.expression.TopicExpression topicExpr ) throws org.apache.ws.notification.topics.expression.InvalidTopicExpressionException, org.apache.ws.notification.base.impl.TopicNotSupportedException, org.apache.ws.notification.base.impl.NoCurrentMessageOnTopicException { return m_producerHelper.getCurrentMessage( topicExpr ); }