Also, is each client supposed to get each message? Or are you using selectors to ensure that each client only gets messages destined for it?
Your problems sound related to your clients (for which you've posted no code/configs), not your broker, so more detail about them might help bring the problem to light... Tim On Wed, Apr 22, 2015 at 9:05 AM, Tim Bain <tb...@alumni.duke.edu> wrote: > It sounds like maybe you're trying to connect from multiple consumers with > non-unique client IDs. Each consumer needs a unique ID; can you confirm > that you're using unique IDs in each client? Though I'm surprised you > wouldn't see that message till *after* the first client disconnects... > > On Wed, Apr 22, 2015 at 6:06 AM, kalowand <moataz.mou...@isourceglobal.com > > wrote: > >> My case is as follow, I have one master machine and 7 clients machine. I >> add >> activemq between these machines. The clients machine send messages to the >> master machines and the master machine send individual messages to each >> client. >> I implement the following solution, I am using a queues structure as a >> medium for communication. The solution works for only one client server, >> but >> when I add another client to this architecture the activemq does not >> receive >> any messages. until I turn off the first client. giving the following >> exception. >> >> >> javax.jms.InvalidClientIDException: Broker: localhost - Client: >> NC_localhost_outbound already connected from tcp://0.0.0.77:59730 >> >> >> My configuration file: >> >> <?xml version="1.0" encoding="UTF-8"?> >> <beans >> xmlns="http://www.springframework.org/schema/beans"; >> xmlns:amq="http://activemq.apache.org/schema/core"; >> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; >> xsi:schemaLocation="http://www.springframework.org/schema/beans >> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd >> http://activemq.apache.org/schema/core >> http://activemq.apache.org/schema/core/activemq-core.xsd";> >> >> <bean id="environmentVariablesConfiguration" >> class="org.jasypt.encryption.pbe.config.EnvironmentStringPBEConfig"> >> <property name="algorithm" value="PBEWithMD5AndDES" /> >> <property name="passwordEnvName" value="ACTIVEMQ_ENCRYPTION_PASSWORD" >> /> >> </bean> >> >> <bean id="propertyConfigurer" >> >> class="org.jasypt.spring.properties.EncryptablePropertyPlaceholderConfigurer"> >> <constructor-arg ref="configurationEncryptor" /> >> <property name="location" >> value="file:${activemq.base}/conf/credentials-enc.properties"/> >> </bean> >> >> <bean id="configurationEncryptor" >> class="org.jasypt.encryption.pbe.StandardPBEStringEncryptor"> >> <property name="algorithm" value="PBEWithMD5AndDES"/> >> <property name="password" value="activemq"/> >> </bean> >> >> <broker useJmx="true" persistent="false" >> xmlns="http://activemq.apache.org/schema/core"; >> destroyApplicationContextOnStop="true"> >> <destinationPolicy> >> <policyMap> >> <defaultEntry> >> <policyEntry topic="*"> >> <subscriptionRecoveryPolicy> >> <timedSubscriptionRecoveryPolicy recoverDuration="3600000" /> >> </subscriptionRecoveryPolicy> >> </policyEntry> >> </defaultEntry> >> </policyMap> >> </destinationPolicy> >> >> <managementContext> >> <managementContext createConnector="true"> >> <property xmlns="http://www.springframework.org/schema/beans"; >> name="environment"> >> <map xmlns="http://www.springframework.org/schema/beans";> >> <entry >> xmlns="http://www.springframework.org/schema/beans"; >> key="jmx.remote.x.password.file" >> value="conf/jmx.password"/> >> <entry >> xmlns="http://www.springframework.org/schema/beans"; >> key="jmx.remote.x.access.file" >> value="conf/jmx.access"/> >> </map> >> </property> >> </managementContext> >> </managementContext> >> >> <plugins> >> >> <simpleAuthenticationPlugin> >> <users> >> <authenticationUser username="system" >> password="${activemq.password}" groups="users,admins"/> >> <authenticationUser username="user" >> password="${user.password}" groups="users"/> >> <authenticationUser username="guest" >> password="${guest.password}" groups="guests"/> >> </users> >> </simpleAuthenticationPlugin> >> >> >> >> <authorizationPlugin> >> <map> >> <authorizationMap> >> <authorizationEntries> >> <authorizationEntry queue=">" read="admins" write="admins" >> admin="admins" /> >> <authorizationEntry queue="USERS.>" read="users" >> write="users" >> admin="users" /> >> >> <authorizationEntry queue="1000.>" read="users" >> write="users" admin="users" /> >> <authorizationEntry queue="1001.>" read="users" >> write="users" >> admin="users" /> >> >> <authorizationEntry queue="Ack-reply.>" read="users" >> write="users" >> admin="users" /> >> >> <authorizationEntry queue="server1000.>" read="users" >> write="users" >> admin="users" /> >> >> <authorizationEntry queue="GUEST.>" read="guests" >> write="guests,users" admin="guests,users" /> >> <authorizationEntry queue="TEST.Q" read="guests" >> write="guests" /> >> <authorizationEntry topic=">" read="admins" write="admins" >> admin="admins" /> >> <authorizationEntry topic="USERS.>" read="users" >> write="users" >> admin="users" /> >> <authorizationEntry topic="GUEST.>" read="guests" >> write="guests,users" admin="guests,users" /> >> >> <authorizationEntry topic="ActiveMQ.Advisory.>" read="users" >> write="users" admin="users"/> >> <authorizationEntry topic="ActiveMQ.Agent.>" read="users" >> write="users" admin="users"/> >> </authorizationEntries> >> </authorizationMap> >> </map> >> </authorizationPlugin> >> </plugins> >> >> >> <systemUsage> >> <systemUsage> >> <memoryUsage> >> <memoryUsage percentOfJvmHeap="70" /> >> </memoryUsage> >> <storeUsage> >> <storeUsage limit="10 gb"/> >> </storeUsage> >> <tempUsage> >> <tempUsage limit="50 gb"/> >> </tempUsage> >> </systemUsage> >> </systemUsage> >> >> >> <transportConnectors> >> <transportConnector name="default" uri="tcp://0.0.0.0:61616"/> >> </transportConnectors> >> >> </broker> >> >> >> <commandAgent xmlns="http://activemq.apache.org/schema/core"; >> brokerUrl="vm://localhost" username="${activemq.username}" >> password="${activemq.password}"/> >> >> <import resource="jetty.xml"/> >> <import resource="camel.xml"/> >> >> </beans> >> My environment is as follow : java 6, ubuntu12.04, activemq 5.10.2 >> >> I have two questions : >> 1- Why this exception happened ? >> 2- Is my configuration the best one in my this case, if no, what is the >> best >> configuration ? >> >> >> >> -- >> View this message in context: >> http://activemq.2283324.n4.nabble.com/multiple-clients-one-server-architicture-using-queues-tp4695425.html >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> > >
