connections for every message instead of every client

[craigpnnl]

This is is an issue.

[craigpnnl]

The framework seems to handle this already. Looking at the create method from the ClientFactory service this will only create a new client if a client instances isn't available. Therefore multiple calls to create will not create new clients but reuse the ones already connected based upon protocol.

@Override
public synchronized Client create(PROTOCOL protocol) {
    GossClient client = null;
    for(GossClient c: clientInstances){

        if(!c.isUsed() && c.getProtocol().equals(protocol)){
            client = c;
            client.setUsed(true);
            break;
        }
    }

    if(client == null){
        if (sslEnabled){
            client = new GossClient()
                        .setProtocol(PROTOCOL.SSL)
                        .setUri((String)properties.get(ClientFactory.DEFAULT_BROKER_URI))
                        .setClientTrustStorePassword((String)properties.get(GossCoreContants.PROP_SSL_CLIENT_TRUSTSTORE_PASSWORD))
                        .setClientTrustStore((String)properties.get(GossCoreContants.PROP_SSL_CLIENT_TRUSTSTORE));                          
        }
        else{
            client = new GossClient()
                            .setProtocol(protocol)
                            .setUri((String)properties.get(GossCoreContants.PROP_OPENWIRE_URI));
        }
        clientInstances.add(client);
    }

    return client;
}