Examples of org.springframework.data.redis.connection.util.ByteArrayWrapper

Package org.springframework.data.redis.connection.util

Examples of org.springframework.data.redis.connection.util.ByteArrayWrapper

org.springframework.data.redis.connection.util.ByteArrayWrapper
Simple wrapper class used for wrapping arrays so they can be used as keys inside maps. @author Costin Leau

    }
    set.addAll(topics);


    for (Topic topic : topics) {


      ByteArrayWrapper holder = new ByteArrayWrapper(serializer.serialize(topic.getTopic()));


      if (topic instanceof ChannelTopic) {
        Collection<MessageListener> collection = channelMapping.get(holder);
        if (collection == null) {
          collection = new CopyOnWriteArraySet<MessageListener>();
          channelMapping.put(holder, collection);
        }
        collection.add(listener);
        channels.add(holder.getArray());


        if (trace)
          logger.trace("Adding listener '" + listener + "' on channel '" + topic.getTopic() + "'");
      }


      else if (topic instanceof PatternTopic) {
        Collection<MessageListener> collection = patternMapping.get(holder);
        if (collection == null) {
          collection = new CopyOnWriteArraySet<MessageListener>();
          patternMapping.put(holder, collection);
        }
        collection.add(listener);
        patterns.add(holder.getArray());


        if (trace)
          logger.trace("Adding listener '" + listener + "' for pattern '" + topic.getTopic() + "'");
      }

View Full Code Here

      }
      topics = set;
    }


    for (Topic topic : topics) {
      ByteArrayWrapper holder = new ByteArrayWrapper(serializer.serialize(topic.getTopic()));


      if (topic instanceof ChannelTopic) {
        remove(listener, topic, holder, channelMapping, channelsToRemove);


        if (trace) {

View Full Code Here

    public void onMessage(Message message, byte[] pattern) {
      Collection<MessageListener> listeners = null;


      // if it's a pattern, disregard channel
      if (pattern != null && pattern.length > 0) {
        listeners = patternMapping.get(new ByteArrayWrapper(pattern));
      } else {
        pattern = null;
        // do channel matching first
        listeners = channelMapping.get(new ByteArrayWrapper(message.getChannel()));
      }


      if (!CollectionUtils.isEmpty(listeners)) {
        dispatchMessage(listeners, message, pattern);
      }

View Full Code Here

TOP

Related Classes of org.springframework.data.redis.connection.util.ByteArrayWrapper

org.springframework.data.redis.listener.RedisMessageListenerContainer

org.springframework.data.redis.listener.RedisMessageListenerContainer$DispatchMessageListener

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.