本文整理了Java中org.apache.helix.model.Message.getRelaySrcHost()方法的一些代码示例，展示了Message.getRelaySrcHost()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.getRelaySrcHost()方法的具体详情如下：
包路径：org.apache.helix.model.Message
类名称：Message
方法名：getRelaySrcHost

Message.getRelaySrcHost介绍

暂无

代码示例

代码示例来源：origin: apache/helix

+ msg.getResourceName() + "." + msg.getPartitionName() + "|" + msg
.getPartitionNames() + " from:" + msg.getFromState() + " to:" + msg.getToState()
+ ", relayFrom: " + msg.getRelaySrcHost() + ", attached to message: " + message
.getMsgId());

代码示例来源：origin: org.apache.helix/helix-core

+ msg.getResourceName() + "." + msg.getPartitionName() + "|" + msg
.getPartitionNames() + " from:" + msg.getFromState() + " to:" + msg.getToState()
+ ", relayFrom: " + msg.getRelaySrcHost() + ", attached to message: " + message
.getMsgId());

代码示例来源：origin: org.apache.helix/helix-core

+ "." + _message.getPartitionName() + "|" + _message.getPartitionNames() + " from:"
+ _message.getFromState() + " to:" + _message.getToState() + ", relayedFrom: "
+ _message.getRelaySrcHost());

代码示例来源：origin: apache/helix

+ "." + _message.getPartitionName() + "|" + _message.getPartitionNames() + " from:"
+ _message.getFromState() + " to:" + _message.getToState() + ", relayedFrom: "
+ _message.getRelaySrcHost());

代码示例来源：origin: org.apache.helix/helix-core

LOG.info(
  "Dropping expired message. mid: " + message.getId() + ", from: " + message.getMsgSrc() + " relayed from: "
    + message.getRelaySrcHost());
reportAndRemoveMessage(message, accessor, instanceName, ProcessedMessageState.DISCARDED);
continue;

代码示例来源：origin: apache/helix

LOG.info(
  "Dropping expired message. mid: " + message.getId() + ", from: " + message.getMsgSrc()
    + " relayed from: " + message.getRelaySrcHost());
reportAndRemoveMessage(message, accessor, instanceName, ProcessedMessageState.DISCARDED);
continue;

代码示例来源：origin: apache/helix

Assert.assertEquals(relayMessage.getMsgSubType(), Message.MessageType.RELAYED_MESSAGE.name());
Assert.assertEquals(relayMessage.getTgtName(), newMasterInstance);
Assert.assertEquals(relayMessage.getRelaySrcHost(), masterInstance);
Assert.assertEquals(relayMessage.getFromState(), MasterSlaveSMD.States.SLAVE.name());
Assert.assertEquals(relayMessage.getToState(), MasterSlaveSMD.States.MASTER.name());

代码示例来源：origin: org.apache.helix/helix-core

_currentStateDelta.setTriggerHost(partitionKey, _message.getRelaySrcHost());
} else {
 _currentStateDelta.setTriggerHost(partitionKey, _message.getMsgSrc());

代码示例来源：origin: apache/helix

_currentStateDelta.setTriggerHost(partitionKey, _message.getRelaySrcHost());
} else {
 _currentStateDelta.setTriggerHost(partitionKey, _message.getMsgSrc());

代码示例来源：origin: apache/helix

Assert.assertEquals(relayMessage.getMsgSubType(), Message.MessageType.RELAYED_MESSAGE.name());
Assert.assertEquals(relayMessage.getTgtName(), secondMaster);
Assert.assertEquals(relayMessage.getRelaySrcHost(), initialMaster);
Assert.assertEquals(relayMessage.getFromState(), MasterSlaveSMD.States.SLAVE.name());
Assert.assertEquals(relayMessage.getToState(), MasterSlaveSMD.States.MASTER.name());
Assert.assertEquals(relayMessage.getMsgSubType(), Message.MessageType.RELAYED_MESSAGE.name());
Assert.assertEquals(relayMessage.getTgtName(), thirdMaster);
Assert.assertEquals(relayMessage.getRelaySrcHost(), secondMaster);
Assert.assertEquals(relayMessage.getFromState(), MasterSlaveSMD.States.SLAVE.name());
Assert.assertEquals(relayMessage.getToState(), MasterSlaveSMD.States.MASTER.name());

代码示例来源：origin: apache/helix

Assert.assertEquals(relayMessage.getMsgSubType(), Message.MessageType.RELAYED_MESSAGE.name());
Assert.assertEquals(relayMessage.getTgtName(), newMasterInstance);
Assert.assertEquals(relayMessage.getRelaySrcHost(), masterInstance);
Assert.assertEquals(relayMessage.getFromState(), MasterSlaveSMD.States.SLAVE.name());
Assert.assertEquals(relayMessage.getToState(), MasterSlaveSMD.States.MASTER.name());