Examples of addChannel()

Examples of org.infinispan.server.websocket.CacheListener.addChannel()

47
48
49
50
51
52
53
54
55
56
57
    String[] keyTokens = key.split(",");   
    for(String keyToken : keyTokens) {
      ChannelNotifyParams notifyParams = new ChannelNotifyParams(ctx.channel(), keyToken, onEvents);
     
      if(opCode.equals("notify")) {
        listener.addChannel(notifyParams);
        // And push the value to the channel (if it's not wildcard)...
        if(!keyToken.equals("*")) {
          ChannelUtils.pushCacheValue(keyToken, cache, ctx);
        }
      } else if(opCode.equals("unnotify")) {
View Full Code Here

Examples of org.jasig.portal.layout.dlm.remoting.registry.ChannelCategoryBean.addChannel()

137
138
139
140
141
142
143
144
145
146
147
   
    for(IChannelDefinition channelDef : channels) {
     
      // construct a new channel bean from this channel
      ChannelBean channel = new ChannelBean(channelDef);
      categoryBean.addChannel(channel);
     
      // remove the channel of the list of all channels
      allChannels.remove(channel);
    }
View Full Code Here

Examples of org.jasig.portal.layout.dlm.remoting.registry.ChannelRegistryBean.addChannel()

112
113
114
115
116
117
118
119
120
121
122
        EntityIdentifier ei = user.getEntityIdentifier();
          IAuthorizationPrincipal ap = AuthorizationService.instance().newPrincipal(ei.getKey(), ei.getType());

          for (IChannelDefinition channel : allChannels) {
              if (ap.canManage(channel.getId())) {
                  registry.addChannel(new ChannelBean(channel));
              }
          }
      }
   
    return registry;
View Full Code Here

Examples of org.jboss.aerogear.simplepush.server.datastore.model.UserAgentDTO.addChannel()

102
103
104
105
106
107
108
109
110
111
112
            public Boolean perform(final EntityManager em) {
                UserAgentDTO userAgent = em.find(UserAgentDTO.class, channel.getUAID());
                if (userAgent == null) {
                    userAgent = new UserAgentDTO(channel.getUAID());
                }
                userAgent.addChannel(channel.getChannelId(), channel.getVersion(), channel.getEndpointToken());
                em.merge(userAgent);
                return Boolean.TRUE;
            }
        };
        try {
View Full Code Here

Examples of org.openhab.binding.homematic.internal.model.HmDevice.addChannel()

183
184
185
186
187
188
189
190
191
192
193
    FieldUtils.writeField(device, "hmInterface", HmInterface.HOMEGEAR, true);

    Object[] channelList = (Object[]) deviceData.get("CHANNELS");
    for (int i = 0; i < channelList.length; i++) {
      Map<String, ?> channelData = (Map<String, ?>) channelList[i];
      device.addChannel(parseChannel(device, channelData));
    }

    return device;
  }
View Full Code Here

Examples of org.switchyard.component.common.knowledge.config.model.v1.V1ChannelsModel.addChannel()

123
124
125
126
127
128
129
130
131
132
133
                    interfaceModel.setInterface(interfaze.getName());
                    componentReferenceModel.setInterface(interfaceModel);
                    componentModel.addReference(componentReferenceModel);
                }
            }
            channelsModel.addChannel(channelModel);
        }
        return channelsModel;
    }

    /**
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.