@Test public void testResolveRoutingKeyFromEmptyHeaders() { Map<String, Object> headers = MapBuilder.<String, Object> map(RuntimeBundleInfoMessageHeaders.APP_NAME, "") .with(RuntimeBundleInfoMessageHeaders.SERVICE_NAME, "service-name"); String routingKey = subject.resolve(headers); assertThat(routingKey).isEqualTo("engineEvents.service-name._"); }
@Override public String resolve(Map<String, Object> headers) { return build(headers, HEADER_KEYS); }
AuditProducerRoutingKeyResolver extends AbstractMessageHeadersRoutingKeyResolver { @Override public String resolve(Map<String, Object> headers) { return build(headers, HEADER_KEYS); } }
AuditProducerRoutingKeyResolver extends AbstractMessageHeadersRoutingKeyResolver { @Override public String resolve(Map<String, Object> headers) { return build(headers, HEADER_KEYS); }  }
AuditProducerRoutingKeyResolver extends AbstractMessageHeadersRoutingKeyResolver { @Override public String resolve(Map<String, Object> headers) { return build(headers, HEADER_KEYS); }  @Override String resolve(Map<String, Object> headers); @Override String getPrefix(); }
AuditProducerRoutingKeyResolver extends AbstractMessageHeadersRoutingKeyResolver { @Override public String resolve(Map<String, Object> headers) { return build(headers, HEADER_KEYS); }  @Override String resolve(Map<String, Object> headers); @Override String getPrefix(); final String ROUTING_KEY_PREFIX; final String[] HEADER_KEYS; }