import org.globus.wsrf.NotifyCallback; //导入依赖的package包/类
/**
* Call this method if you want to subscribe and provide a NotifyCallback to handle the
* messages
*/
public org.oasis.wsn.SubscribeResponse subscribe(QName qname, NotifyCallback callback) throws RemoteException, ContainerException, MalformedURIException {
    synchronized (portTypeMutex) {
        configureStubSecurity((Stub) portType, "subscribe");

        if (consumer == null) {
            // Create client side notification consumer
            consumer = org.globus.wsrf.NotificationConsumerManager.getInstance();
            consumer.startListening();
            consumerEPR = consumer.createNotificationConsumer(callback);
        }

        org.oasis.wsn.Subscribe params = new org.oasis.wsn.Subscribe();
        params.setUseNotify(Boolean.TRUE);
        params.setConsumerReference(consumerEPR);
        org.oasis.wsn.TopicExpressionType topicExpression = new org.oasis.wsn.TopicExpressionType();
        topicExpression.setDialect(org.globus.wsrf.WSNConstants.SIMPLE_TOPIC_DIALECT);
        topicExpression.setValue(qname);
        params.setTopicExpression(topicExpression);
        return portType.subscribe(params);
   }
}
 

import org.globus.wsrf.NotifyCallback; //导入依赖的package包/类
/** returns an EPR to a newly created consumer, such that notifications
sent to this consumer will be delivered to the callback. */
public EndpointReferenceType getConsumer(NotifyCallback callback)
{
    EndpointReferenceType consumerEPR;

    try {
        consumerEPR = consumerManager.createNotificationConsumer(callback);
    } catch(ResourceException re) {
        logger.error("Exception getting a consumer");
        return null;
    }
    return consumerEPR;
}