Examples of addChannel()

Examples of org.apache.qpid.server.protocol.v0_8.AMQProtocolSession.addChannel()

69
70
71
72
73
74
75
76
77
78
79
        }
        _logger.info("Connecting to: " + virtualHost.getName());

        final AMQChannel channel = new AMQChannel(session,channelId, virtualHost.getMessageStore());

        session.addChannel(channel);

        ChannelOpenOkBody response;

        ProtocolVersion pv = session.getProtocolVersion();
View Full Code Here

Examples of org.apache.qpid.server.protocol.v0_8.AMQProtocolSession.addChannel()

70
71
72
73
74
75
76
77
78
79
80
        }
        _logger.info("Connecting to: " + virtualHost.getName());

        final AMQChannel channel = new AMQChannel(session,channelId, virtualHost.getMessageStore());

        session.addChannel(channel);

        ChannelOpenOkBody response;

        ProtocolVersion pv = session.getProtocolVersion();
View Full Code Here

Examples of org.apache.qpid.server.protocol.v0_8.AMQProtocolSession.addChannel()

70
71
72
73
74
75
76
77
78
79
80
        }
        _logger.info("Connecting to: " + virtualHost.getName());

        final AMQChannel channel = new AMQChannel(session,channelId, virtualHost.getMessageStore());

        session.addChannel(channel);

        ChannelOpenOkBody response;

        ProtocolVersion pv = session.getProtocolVersion();
View Full Code Here

Examples of org.grouplens.lenskit.scored.ScoredIdBuilder.addChannel()

136
137
138
139
140
141
142
143
144
145
146
            }
            for (ScoredId id: results) {
                ScoredIdBuilder copy = ScoredIds.copyBuilder(id);
                for (Pair<Symbol,SparseVector> pair: cvs) {
                    if (pair.getRight().containsKey(id.getId())) {
                        copy.addChannel(pair.getLeft(), pair.getRight().get(id.getId()));
                    }
                }
                for (Pair<TypedSymbol<?>, Long2ObjectMap<?>> pair: channels) {
                    if (pair.getRight().containsKey(id.getId())) {
                        copy.addChannel((TypedSymbol) pair.getLeft(), pair.getRight().get(id.getId()));
View Full Code Here

Examples of org.grouplens.lenskit.scored.ScoredIdBuilder.addChannel()

141
142
143
144
145
146
147
148
149
150
151
                        copy.addChannel(pair.getLeft(), pair.getRight().get(id.getId()));
                    }
                }
                for (Pair<TypedSymbol<?>, Long2ObjectMap<?>> pair: channels) {
                    if (pair.getRight().containsKey(id.getId())) {
                        copy.addChannel((TypedSymbol) pair.getLeft(), pair.getRight().get(id.getId()));
                    }
                }
                builder.add(copy.build());
            }
            return builder.finish();
View Full Code Here

Examples of org.grouplens.lenskit.scored.ScoredIdListBuilder.addChannel()

123
124
125
126
127
128
129
130
131
132
133
        if (!scores.getChannelSymbols().isEmpty()) {
            ScoredIdListBuilder builder = ScoredIds.newListBuilder(results.size());
            List<Pair<Symbol,SparseVector>> cvs = Lists.newArrayList();
            List<Pair<TypedSymbol<?>, Long2ObjectMap<?>>> channels = Lists.newArrayList();
            for (Symbol sym: scores.getChannelVectorSymbols()) {
                builder.addChannel(sym, Double.NaN);
                cvs.add(Pair.of(sym, scores.getChannelVector(sym)));
            }
            for (TypedSymbol<?> sym: scores.getChannelSymbols()) {
                if (!sym.getType().equals(Double.class)) {
                    builder.addChannel(sym);
View Full Code Here

Examples of org.grouplens.lenskit.scored.ScoredIdListBuilder.addChannel()

128
129
130
131
132
133
134
135
136
137
138
                builder.addChannel(sym, Double.NaN);
                cvs.add(Pair.of(sym, scores.getChannelVector(sym)));
            }
            for (TypedSymbol<?> sym: scores.getChannelSymbols()) {
                if (!sym.getType().equals(Double.class)) {
                    builder.addChannel(sym);
                    channels.add((Pair) Pair.of(sym, scores.getChannel(sym)));
                }
            }
            for (ScoredId id: results) {
                ScoredIdBuilder copy = ScoredIds.copyBuilder(id);
View Full Code Here

Examples of org.grouplens.lenskit.scored.ScoredIdListBuilder.addChannel()

89
90
91
92
93
94
95
96
97
98
99
            items.add(sid.getId());
        }

        SparseVector scores = scorer.score(user, items);
        ScoredIdListBuilder builder = ScoredIds.newListBuilder(recs.size());
        builder.addChannel(ORIGINAL_SCORE_SYMBOL);
        for (ScoredId sid: recs) {
            // FIXME Make this not allocate so much memory
            builder.add(ScoredIds.copyBuilder(sid)
                                 .setScore(scores.get(sid.getId(), Double.NaN))
                                 .addChannel(ORIGINAL_SCORE_SYMBOL, sid.getScore())
View Full Code Here

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

69
70
71
72
73
74
75
76
77
78
79
    String[] keyTokens = key.split(",");   
    for(String keyToken : keyTokens) {
      ChannelNotifyParams notifyParams = new ChannelNotifyParams(ctx.getChannel(), 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.infinispan.server.websocket.CacheListener.addChannel()

46
47
48
49
50
51
52
53
54
55
56
    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
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.