@Test public void forwardSendResult() { assertThat(messageSender.send(event).aborted(), is(false)); TxEvent rejectEvent = new TxStartedEvent(globalTxId, localTxId, parentTxId, "reject", 0, "", 0, "blah"); assertThat(messageSender.send(rejectEvent).aborted(), is(true)); }
@Override public AlphaResponse send(TxEvent event) { return (AlphaResponse) send("sendEvent", event); }
LoadBalancedClusterMessageSender implements MessageSender { @Override public AlphaResponse send(TxEvent event) { return (AlphaResponse) send("sendEvent", event); } }
LoadBalancedClusterMessageSender implements MessageSender { @Override public AlphaResponse send(TxEvent event) { return (AlphaResponse) send("sendEvent", event); } LoadBalancedClusterMessageSender(AlphaClusterConfig clusterConfig,
      MessageSerializer serializer,
      MessageDeserializer deserializer,
      ServiceConfig serviceConfig,
      MessageHandler handler,
      int reconnectDelay,
      Tracing tracing);   LoadBalancedClusterMessageSender(MessageSender... messageSenders); }
LoadBalancedClusterMessageSender implements MessageSender { @Override public AlphaResponse send(TxEvent event) { return (AlphaResponse) send("sendEvent", event); } LoadBalancedClusterMessageSender(AlphaClusterConfig clusterConfig,
      MessageSerializer serializer,
      MessageDeserializer deserializer,
      ServiceConfig serviceConfig,
      MessageHandler handler,
      int reconnectDelay,
      Tracing tracing);   LoadBalancedClusterMessageSender(MessageSender... messageSenders); @Override void onConnected(); @Override void onDisconnected(); @Override void close(); @Override String target(); @Override AlphaResponse send(TxEvent event); @Override Set<String> send(Set<String> localTxIdSet); @Override String reportMessageToServer(KafkaMessage message); @Override String reportAccidentToServer(AccidentHandling accidentHandling); @Override GrpcConfigAck readConfigFromServer(int type, String category); }
LoadBalancedClusterMessageSender implements MessageSender { @Override public AlphaResponse send(TxEvent event) { return (AlphaResponse) send("sendEvent", event); } LoadBalancedClusterMessageSender(AlphaClusterConfig clusterConfig,
      MessageSerializer serializer,
      MessageDeserializer deserializer,
      ServiceConfig serviceConfig,
      MessageHandler handler,
      int reconnectDelay,
      Tracing tracing);   LoadBalancedClusterMessageSender(MessageSender... messageSenders); @Override void onConnected(); @Override void onDisconnected(); @Override void close(); @Override String target(); @Override AlphaResponse send(TxEvent event); @Override Set<String> send(Set<String> localTxIdSet); @Override String reportMessageToServer(KafkaMessage message); @Override String reportAccidentToServer(AccidentHandling accidentHandling); @Override GrpcConfigAck readConfigFromServer(int type, String category);  }