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 );
    }