interconnect/core/src/main/java/de/taimos/dvalin/interconnect/core/InterconnectConnector.java
/**
     * @param topicName Topic name
     * @param selector  JMS selector (or null or empty string := no selector)
     * @param timeout   Timeout in milliseconds to wait for an Interconnect Object
     * @param secure    Enable secure transport?
     * @return Response
     * @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 topicName Topic name
@param selector  JMS selector (or null or empty string := no selector)
@param timeout   Timeout in milliseconds to wait for an Interconnect Object
@param secure    Enable secure transport.
@param topicName Topic name @param selector JMS selector ( or null or empty string : = no selector ) @param timeout Timeout in milliseconds to wait for an Interconnect Object @param secure Enable secure transport .
public static Response receiveFromTopicEnhanced(final String topicName, final String selector, final long timeout, final boolean secure) throws InfrastructureException, CryptoException, IOException {
        Preconditions.checkNotNull(topicName, TOPIC_NAME_NULL_ERROR);
        final TextMessage response = MessageConnector.receiveFromTopic(topicName, selector, timeout, secure);
        try {
            return new Response(InterconnectMapper.fromJson(response.getText()), response);
        } catch (final JMSException e) {
            throw new InfrastructureException("Failed to read message");
        }
    }
public static Response receiveFromTopicEnhanced ( final String topicName , final String selector , final long timeout , final boolean secure ) throws InfrastructureException , CryptoException , IOException { Preconditions . checkNotNull ( topicName , TOPIC_NAME_NULL_ERROR ) ; final TextMessage response = MessageConnector . receiveFromTopic ( topicName , selector , timeout , secure ) ; try { return new Response ( InterconnectMapper . fromJson ( response . getText ( ) ) , response ) ; } catch ( final JMSException e ) { throw new InfrastructureException ( "Failed to read message" ) ; } }
@param topicName Topic name
 @param selector  JMS selector (or null or empty string := no selector)
 @param timeout   Timeout in milliseconds to wait for an Interconnect Object
 @param secure    Enable secure transport?
@param topicName Topic name @param selector JMS selector ( or null or empty string : = no selector ) @param timeout Timeout in milliseconds to wait for an Interconnect Object @param secure Enable secure transport?