interconnect/core/src/main/java/de/taimos/dvalin/interconnect/core/InterconnectConnector.java
/**
     * @param destination      Destination
     * @param ico              Interconnect Object
     * @param customHeaders    Headers (or null)
     * @param secure           Enable secure transport?
     * @param replyToQueueName Reply is send to this queue (or null)
     * @param correlationId    Correlation id (or null)
     * @throws InfrastructureException If an infrastructure error occurs
     * @throws CryptoException         If the message could not be encrypted
     * @throws JsonGenerationException if the JSON data could not be generated
     * @throws JsonMappingException    if the object could not be mapped to a JSON string
     * @throws IOException             if an I/O related problem occurred
     */
@param destination      Destination
@param ico              Interconnect Object
@param customHeaders    Headers (or null)
@param secure           Enable secure transport.
@param destination Destination @param ico Interconnect Object @param customHeaders Headers ( or null ) @param secure Enable secure transport .
public static void sendToDestination(final Destination destination, final InterconnectObject ico, final Map<String, Object> customHeaders, final boolean secure, final String replyToQueueName, final String correlationId) throws InfrastructureException, CryptoException, IOException {
        Preconditions.checkNotNull(destination, "Destination was null");
        Preconditions.checkNotNull(ico, INTERCONNECT_OBJECT_NULL_ERROR);
        final String body = InterconnectMapper.toJson(ico);
        final Map<String, Object> headers;
        if (customHeaders == null) {
            headers = new HashMap<>(1);
        } else {
            headers = new HashMap<>(customHeaders);
        }
        headers.put(InterconnectConnector.HEADER_ICO_CLASS, ico.getClass().getName());
        MessageConnector.sendToDestination(destination, body, headers, secure, replyToQueueName, correlationId);
    }
public static void sendToDestination ( final Destination destination , final InterconnectObject ico , final Map < String , Object > customHeaders , final boolean secure , final String replyToQueueName , final String correlationId ) throws InfrastructureException , CryptoException , IOException { Preconditions . checkNotNull ( destination , "Destination was null" ) ; Preconditions . checkNotNull ( ico , INTERCONNECT_OBJECT_NULL_ERROR ) ; final String body = InterconnectMapper . toJson ( ico ) ; final Map < String , Object > headers ; if ( customHeaders == null ) { headers = new HashMap < > ( 1 ) ; } else { headers = new HashMap < > ( customHeaders ) ; } headers . put ( InterconnectConnector . HEADER_ICO_CLASS , ico . getClass ( ) . getName ( ) ) ; MessageConnector . sendToDestination ( destination , body , headers , secure , replyToQueueName , correlationId ) ; }
@param destination      Destination
 @param ico              Interconnect Object
 @param customHeaders    Headers (or null)
 @param secure           Enable secure transport?
@param destination Destination @param ico Interconnect Object @param customHeaders Headers ( or null ) @param secure Enable secure transport?