Examples of UnsubscribeMessage

asia.stampy.client.message.unsubscribe.UnsubscribeMessage
The Class UnsubscribeMessage.
ch.rasc.wampspring.message.UnsubscribeMessage
/spec/#unsubscribe_message">WAMP specification
org.eclipse.ecf.pubsub.impl.UnsubscribeMessage

Examples of asia.stampy.client.message.unsubscribe.UnsubscribeMessage


    }
  }


  private void sendUnsubscribe(String id) throws InterceptException {
    UnsubscribeMessage message = new UnsubscribeMessage(id);
    getGateway().broadcastMessage(message);
  }

View Full Code Here

Examples of asia.stampy.client.message.unsubscribe.UnsubscribeMessage

      break;
    case SUBSCRIBE:
      message = (MSG) new SubscribeMessage();
      break;
    case UNSUBSCRIBE:
      message = (MSG) new UnsubscribeMessage();
      break;
    default:
      break;


    }

View Full Code Here

Examples of ch.rasc.wampspring.message.UnsubscribeMessage

    // For a proper cleanup we now create an UnsubscribeMessage for every
    // listed topicURI, send them to the AnnotationMethodHandler so he can
    // call any available method that is annotated with
    // @WampUnsubscribeListener
    for (String topicURI : topicURIs) {
      UnsubscribeMessage unsubscribeMessage = new UnsubscribeMessage(topicURI);
      unsubscribeMessage.addHeader(WampMessageHeader.WEBSOCKET_SESSION_ID, sessionId);
      annotationMethodHandler.handleMessage(unsubscribeMessage);
    }
    annotationMethodHandler.unregisterSessionFromAllPrefixCurie(sessionId);
  }

View Full Code Here

Examples of ch.rasc.wampspring.message.UnsubscribeMessage

    case SUBSCRIBE:
      SubscribeMessage subscribeMessage = (SubscribeMessage) message;
      handlePubSubMessage(subscribeMessage, null, subscribeMessage.getTopicURI(), subscribeMethods);
      break;
    case UNSUBSCRIBE:
      UnsubscribeMessage unsubscribeMessage = (UnsubscribeMessage) message;
      handlePubSubMessage(unsubscribeMessage, null, unsubscribeMessage.getTopicURI(), unsubscribeMethods);
      break;
    case PREFIX:
      PrefixMessage prefixMessage = (PrefixMessage) message;
      handlePrefixMessage(prefixMessage);
      break;

View Full Code Here

Examples of org.eclipse.ecf.pubsub.impl.UnsubscribeMessage

      
      subscribers.remove(requestorID);
      if (subscribers.isEmpty()) {
        ISharedObjectContext ctx = config.getContext();
        try {
          ctx.sendMessage(config.getHomeContainerID(), new UnsubscribeMessage());
        } catch (IOException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.