Examples of UpstreamMessageEvent

Examples of org.jboss.netty.channel.UpstreamMessageEvent

108
109
110
111
112
113
114
115
        RpcMessage response = RpcMessage.newBuilder()
                .setType(MessageType.RESPONSE)
                .setId(1)
                .setResponse(sudokuResponse.toByteString())
                .build();
        channel.messageReceived(null, new UpstreamMessageEvent(mockChannel, response, null));
        assertEquals(sudokuResponse, gotResponse);
    }
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

147
148
149
150
151
152
153
154
155
156
157
                .setService(SudokuService.getDescriptor().getFullName())
                .setMethod("Solve")
                .setRequest(sudokuRequest.toByteString())
                .build();

        channel.messageReceived(null, new UpstreamMessageEvent(mockChannel, request, null));
        assertEquals(sudokuRequest, gotRequest);

        RpcMessage response = RpcMessage.newBuilder()
                .setType(MessageType.RESPONSE)
                .setId(2)
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

771
772
773
774
775
776
777
778
779
               }
            }
            active = true;
            handShakeFuture.run();
         }
         MessageEvent event = new UpstreamMessageEvent(e.getChannel(), response.getContent(), e.getRemoteAddress());
         waitingGet = false;
         ctx.sendUpstream(event);
      }
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

86
87
88
89
90
91
92
93
      Map<String, List<String>> jsonMap = GSON.fromJson(json, MAP_TYPE);
      GDATFormatUtil.encode(jsonMap.get("data"), schema, outputStream, false);
      ChannelBuffer dataRecordBuffer = ChannelBuffers.copiedBuffer(outputStream.getByteArray(), 0,
                                                                   outputStream.length());
      outputStream.reset();
      MessageEvent newMessageEvent = new UpstreamMessageEvent(ctx.getChannel(), dataRecordBuffer, e.getRemoteAddress());
      super.messageReceived(ctx, newMessageEvent);
    }
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

123
124
125
126
127
128
129
130
131
132
133
      buffer.writeBytes((ChannelBuffer) e.getMessage());
      while (true) {
        if (dataRecordLength != -1 && buffer.readableBytes() >= dataRecordLength) {
          ChannelBuffer channelBuffer = buffer.readBytes(dataRecordLength);
          dataRecordLength = -1;
          super.messageReceived(ctx, new UpstreamMessageEvent(e.getChannel(), channelBuffer, e.getRemoteAddress()));
        } else if (dataRecordLength == -1 && buffer.readableBytes() >= Ints.BYTES) {
          //We want to pass both the length bytes and the data bytes and so using getBytes so that readerIndex
          //is not changed.
          buffer.getBytes(buffer.readerIndex(), lengthBytes, 0, Ints.BYTES);
          //Length Data is encoded as an Integer in Big Endian Format.
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

191
192
193
194
195
196
197
198
199
200
201
          ctx.getPipeline().remove("headerDecoder");
          LOG.info("Output Stream {} : Received Schema!", outputName);
          //Send any remaining bytes in ChannelBuffer upstream.
          if (buffer.readableBytes() != 0) {
            ChannelBuffer newBuffer = buffer.readBytes(buffer.readableBytes());
            super.messageReceived(ctx, new UpstreamMessageEvent(e.getChannel(), newBuffer, e.getRemoteAddress()));
            break;
          }
        } else {
          break;
        }
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

87
88
89
90
91
92
93
94
95
96
97
        log.debug(new String(Arrays.toString(array)));
        return;
      }

      final MessageEvent eventOut =
          new UpstreamMessageEvent(eventIn.getChannel(), messageDDF,
              null);

      context.sendUpstream(eventOut);

    } else {
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

87
88
89
90
91
92
93
94
95
96
97
        log.debug(new String(Arrays.toString(array)));
        return;
      }

      final MessageEvent eventOut =
          new UpstreamMessageEvent(eventIn.getChannel(), messageDDF,
              null);

      context.sendUpstream(eventOut);

    } else {
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

775
776
777
778
779
780
781
782
783
               }
            }
            active = true;
            handShakeFuture.run();
         }
         MessageEvent event = new UpstreamMessageEvent(e.getChannel(), response.getContent(), e.getRemoteAddress());
         waitingGet = false;
         ctx.sendUpstream(event);
      }
View Full Code Here

Examples of org.jboss.netty.channel.UpstreamMessageEvent

610
611
612
613
614
615
616
617
618
               }
            }
            active = true;
            handShakeFuture.run();
         }
         MessageEvent event = new UpstreamMessageEvent(e.getChannel(), response.getContent(), e.getRemoteAddress());
         waitingGet = false;
         ctx.sendUpstream(event);
      }
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.