activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chif <admire.chif...@gmail.com>
Subject Re: Pushing messages from Adempiere to ActiveMQ
Date Mon, 31 Mar 2008 10:20:41 GMT

Actually i had set the frequency in import processor of one of this broker
giving that error message to 5mins but when i removed that the error is no
more errors.
When i save my record and by way of debugging the send message method in
TopicExport Processor class is able to send with the generated xml but when
i check for the sent messages in activemq_msg table i cannot see the sent
message so i would like to know where is it sending to?I have only two
brokers which am using to test this JMS message sending and on start up they
connect successfully but when i go to my client and generate an xml and send
it somehow its getting lost somewhere or maybe am checking in the wrong
place?

below is the full log of my server:
08:54:10,669 INFO  [Server] Starting JBoss (MX MicroKernel)...
08:54:10,692 INFO  [Server] Release ID: JBoss [Zion] 4.0.2 (build:
CVSTag=JBoss_4_0_2 date=200505022023)
08:54:10,693 INFO  [Server] Home Dir: /Adempiere/jboss
08:54:10,693 INFO  [Server] Home URL: file:/Adempiere/jboss/
08:54:10,693 INFO  [Server] Library URL: file:/Adempiere/jboss/lib/
08:54:10,697 INFO  [Server] Patch URL: null
08:54:10,698 INFO  [Server] Server Name: adempiere
08:54:10,698 INFO  [Server] Server Home Dir:
/Adempiere/jboss/server/adempiere
08:54:10,699 INFO  [Server] Server Home URL:
file:/Adempiere/jboss/server/adempiere/
08:54:10,699 INFO  [Server] Server Data Dir:
/Adempiere/jboss/server/adempiere/data
08:54:10,700 INFO  [Server] Server Temp Dir:
/Adempiere/jboss/server/adempiere/tmp
08:54:10,700 INFO  [Server] Server Config URL:
file:/Adempiere/jboss/server/adempiere/conf/
08:54:10,700 INFO  [Server] Server Library URL:
file:/Adempiere/jboss/server/adempiere/lib/
08:54:10,701 INFO  [Server] Root Deployment Filename: jboss-service.xml
08:54:10,707 INFO  [Server] Starting General Purpose Architecture (GPA)...
08:54:11,656 INFO  [ServerInfo] Java version: 1.5.0_11,Sun Microsystems Inc.
08:54:11,657 INFO  [ServerInfo] Java VM: Java HotSpot(TM) Server VM
1.5.0_11-b03,Sun Microsystems Inc.
08:54:11,657 INFO  [ServerInfo] OS-System: Linux 2.6.21-7.fc7xen,i386
08:54:13,664 INFO  [Server] Core system initialized
08:54:21,351 INFO  [Log4jService$URLWatchTimerTask] Configuring from URL:
resource:log4j.xml
08:54:22,479 INFO  [WebService] Using RMI server codebase:
http://mnit.com:8083/
08:54:23,099 INFO  [NamingService] Started jndi bootstrap jnpPort=1099,
rmiPort=1098, backlog=50, bindAddress=mnit.com/111.14.88.21, Client
SocketFactory=null, Server
SocketFactory=org.jboss.net.sockets.DefaultSocketFactory@ad093076
08:54:30,843 INFO  [Embedded] Catalina naming disabled

08:54:33,549 INFO  [Catalina] Initialization processed in 2595 ms
08:54:33,552 INFO  [StandardService] Starting service jboss.web
08:54:33,668 INFO  [StandardEngine] Starting Servlet Engine: Apache
Tomcat/5.5.9
08:54:33,748 INFO  [StandardHost] XML validation disabled
08:54:33,945 INFO  [Catalina] Server startup in 396 ms
08:54:34,207 INFO  [TomcatDeployer] deploy, ctxPath=/invoker,
warUrl=file:/Adempiere/jboss/server/adempiere/deploy/http-invoker.sar/invoker.war/
08:54:37,795 INFO  [WebappLoader] Dual registration of jndi stream handler:
factory already defined
08:54:39,550 INFO  [TomcatDeployer] deploy, ctxPath=/,
warUrl=file:/Adempiere/jboss/server/adempiere/deploy/jbossweb-tomcat55.sar/ROOT.war/
08:54:45,311 INFO  [TomcatDeployer] deploy, ctxPath=/web-console,
warUrl=file:/home/postgres/Adempiere/jboss/server/adempiere/deploy/management/console-mgr.sar/web-console.war/
08:54:51,751 INFO  [RARDeployment] Required license terms exist view the
META-INF/ra.xml:
file:/Adempiere/jboss/server/adempiere/deploy/activemq-ra.rar/
08:54:52,227 INFO  [XBeanXmlBeanDefinitionReader] Loading XML bean
definitions from class path resource [broker-config.xml]
08:54:53,097 INFO  [ClassPathXmlApplicationContext] Bean factory for
application context
[org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=32260077]:
org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans
[org.springframework.beans.factory.config.PropertyPlaceholderConfigurer,org.apache.activemq.xbean.XBeanBrokerService,postgres-ds];
root of BeanFactory hierarchy
08:54:53,169 INFO  [ClassPathXmlApplicationContext] 3 beans defined in
application context
[org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=32260077]
08:54:53,301 INFO  [CollectionFactory] JDK 1.4+ collections available
08:54:53,310 INFO  [ClassPathXmlApplicationContext] Unable to locate
MessageSource with name 'messageSource': using default
[org.springframework.context.support.DelegatingMessageSource@17a1686]
08:54:53,316 INFO  [ClassPathXmlApplicationContext] Unable to locate
ApplicationEventMulticaster with name 'applicationEventMulticaster': using
default
[org.springframework.context.event.SimpleApplicationEventMulticaster@1f10df7]
08:54:53,320 INFO  [DefaultListableBeanFactory] Pre-instantiating singletons
in factory
[org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans
[org.springframework.beans.factory.config.PropertyPlaceholderConfigurer,org.apache.activemq.xbean.XBeanBrokerService,postgres-ds];
root of BeanFactory hierarchy]
08:54:54,103 INFO  [BrokerService] ActiveMQ 4.0.2 JMS Message Broker
(chifura.broker) is starting
08:54:54,103 INFO  [BrokerService] For help or more information please see:
http://incubator.apache.org/activemq/
08:54:55,588 INFO  [JDBCPersistenceAdapter] Database driver recognized:
[postgresql_native_driver]
08:54:55,924 WARN  [ManagementContext] Failed to start jmx connector: Cannot
bind to URL [rmi://localhost:1099/jmxrmi]:
javax.naming.ServiceUnavailableException [Root exception is
java.rmi.ConnectException: Connection refused to host: localhost; nested
exception is:
        java.net.ConnectException: Connection refused]
08:54:58,817 WARN  [DefaultJDBCAdapter] Could not create JDBC tables; they
could already exist. Failure was: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT
NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250), MSGID_SEQ INTEGER,
EXPIRATION BIGINT, MSG BYTEA, PRIMARY KEY ( ID ) ) Message: ERROR: relation
"activemq_msgs" already exists SQLState: 42P07 Vendor code: 0
08:54:58,819 WARN  [DefaultJDBCAdapter] Could not create JDBC tables; they
could already exist. Failure was: CREATE INDEX ACTIVEMQ_MSGS_MIDX ON
ACTIVEMQ_MSGS (MSGID_PROD,MSGID_SEQ) Message: ERROR: current transaction is
aborted, commands ignored until end of transaction block SQLState: 25P02
Vendor code: 0
08:54:58,821 WARN  [DefaultJDBCAdapter] Could not create JDBC tables; they
could already exist. Failure was: CREATE INDEX ACTIVEMQ_MSGS_CIDX ON
ACTIVEMQ_MSGS (CONTAINER) Message: ERROR: current transaction is aborted,
commands ignored until end of transaction block SQLState: 25P02 Vendor code:
0
08:54:58,823 WARN  [DefaultJDBCAdapter] Could not create JDBC tables; they
could already exist. Failure was: CREATE INDEX ACTIVEMQ_MSGS_EIDX ON
ACTIVEMQ_MSGS (EXPIRATION) Message: ERROR: current transaction is aborted,
commands ignored until end of transaction block SQLState: 25P02 Vendor code:
0
08:54:58,825 WARN  [DefaultJDBCAdapter] Could not create JDBC tables; they
could already exist. Failure was: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID INTEGER, PRIMARY
KEY ( CONTAINER, CLIENT_ID, SUB_NAME)) Message: ERROR: current transaction
is aborted, commands ignored until end of transaction block SQLState: 25P02
Vendor code: 0
08:54:59,047 INFO  [JournalPersistenceAdapter] Journal Recovery Started
from: Active Journal: using 5 x 20.0 Megs at:
/Adempiere/utils/activemq-data/journal
08:54:59,168 INFO  [JournalPersistenceAdapter] Journal Recovered: 0
message(s) in transactions recovered.
08:54:59,605 INFO  [TransportServerThreadSupport] Listening for connections
at: tcp://mnit.com:61616
08:54:59,705 WARN  [MulticastDiscoveryAgent] brokerName not set
08:54:59,749 INFO  [TransportConnector] Connector chifura.broker Started
08:54:59,753 INFO  [NetworkConnector] Establishing network connection
between from vm://chifura.broker?network=true to
failover:(tcp://111.14.88.20:61616)?maxReconnectDelay=1000
08:54:59,858 INFO  [TransportConnector] Connector vm://chifura.broker
Started
08:54:59,947 INFO  [NetworkConnector] Network Connector 111.14.88.20 Started
08:54:59,948 INFO  [BrokerService] ActiveMQ JMS Message Broker
(chifura.broker, ID:mnit.com-36380-1206946493415-1:0) started
08:55:00,234 INFO  [TomcatDeployer] deploy, ctxPath=/jmx-console,
warUrl=file:/Adempiere/jboss/server/adempiere/deploy/jmx-console.war/
08:55:00,471 INFO  [EARDeployer] Init J2EE application:
file:/Adempiere/jboss/server/adempiere/deploy/adempiere.ear/
08:55:01,080 INFO  [DemandForwardingBridge] Network connection between
vm://chifura.broker#0 and tcp://111.14.88.20:61616(wattle.broker) has been
established.
08:55:23,860 INFO  [EjbModule] Deploying adempiere/Status
08:55:24,176 WARN  [EjbModule] Could not load the
org.jboss.webservice.server.ServiceEndpointInterceptor interceptor
08:55:24,322 INFO  [EjbModule] Deploying adempiere/Server
08:55:24,374 WARN  [EjbModule] Could not load the
org.jboss.webservice.server.ServiceEndpointInterceptor interceptor
08:55:25,752 INFO  [EJBDeployer] Deployed:
file:/Adempiere/jboss/server/adempiere/deploy/adempiere.ear/adempiereRoot.jar
08:55:25,859 INFO  [TomcatDeployer] deploy, ctxPath=/adempiere,
warUrl=file:/Adempiere/jboss/server/adempiere/tmp/deploy/tmp35492adempiereApps.war/
08:55:27,833 INFO  [STDOUT]
CLogFile[/Adempiere/log/2008-03-31_0.log,Level=ALL]
08:55:32,148 INFO  [STDOUT] com.mchange.v2.cfg.BasicMultiPropertiesConfig:
Properties object found at resource path [system properties] contains a
value that is not a String:
[/Adempiere/utils/activemq-data/journal/control.dat]
08:55:32,149 INFO  [STDOUT] Skipping...
08:55:32,156 INFO  [STDOUT] com.mchange.v2.cfg.BasicMultiPropertiesConfig:
Properties object found at resource path [system properties] contains a
value that is not a String:
[/Adempiere/utils/activemq-data/journal/control.dat]
08:55:32,157 INFO  [STDOUT] Skipping...
08:55:32,193 INFO  [STDOUT] [INFO] MLog clients using
com.mchange.v2.log.FallbackMLog logging.
08:55:32,842 INFO  [STDOUT] [INFO] Initializing c3p0-0.9.1.2 [built
21-May-2007 15:04:56; debug? true; trace: 10]
08:55:33,262 INFO  [STDOUT] [INFO] Initializing c3p0 pool...
com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 3,
acquireRetryAttempts -> 2, acquireRetryDelay -> 1000, autoCommitOnClose ->
false, automaticTestTable -> null, breakAfterAcquireFailure -> false,
checkoutTimeout -> 0, connectionCustomizerClassName -> null,
connectionTesterClassName ->
com.mchange.v2.c3p0.impl.DefaultConnectionTester, dataSourceName ->
AdempiereDS, debugUnreturnedConnectionStackTraces -> false, description ->
null, driverClass -> org.postgresql.Driver, factoryClassLocation -> null,
forceIgnoreUnresolvedTransactions -> false, identityToken ->
1bqp63l7t105hl310vubi0|1deb5f7, idleConnectionTestPeriod -> 1200,
initialPoolSize -> 10, jdbcUrl ->
jdbc:postgresql://postgreadem350:5432/adempiere?encoding=UNICODE,
maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 1200,
maxIdleTimeExcessConnections -> 1200, maxPoolSize -> 150, maxStatements ->
0, maxStatementsPerConnection -> 0, minPoolSize -> 5, numHelperThreads -> 3,
numThreadsAwaitingCheckoutDefaultUser -> 0, preferredTestQuery -> SELECT
Version FROM AD_System, properties -> {user=******, password=******},
propertyCycle -> 0, testConnectionOnCheckin -> false,
testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0,
usesTraditionalReflectiveProxies -> false ]
08:56:00,690 INFO  [TomcatDeployer] deploy, ctxPath=/admin,
warUrl=file:/Adempiere/jboss/server/adempiere/tmp/deploy/tmp35493adempiereRoot.war/
08:56:08,028 INFO  [TomcatDeployer] deploy, ctxPath=/,
warUrl=file:/Adempiere/jboss/server/adempiere/tmp/deploy/tmp35494adempiereWebCM.war/
08:56:08,515 INFO  [TomcatDeployer] deploy, ctxPath=/wstore,
warUrl=file:/Adempiere/jboss/server/adempiere/tmp/deploy/tmp35495adempiereWebStore.war/
08:56:10,595 INFO  [TomcatDeployer] deploy, ctxPath=/posterita,
warUrl=file:/Adempiere/jboss/server/adempiere/tmp/deploy/tmp35496posterita.war/
08:56:10,691 INFO  [WebappClassLoader]
validateJarFile(/Adempiere/jboss/server/adempiere/./tmp/deploy/tmp35496posterita.war/WEB-INF/lib/servlet.jar)
- jar not loaded. See Servlet Spec 2.3, section 9.7.2. Offending class:
javax/servlet/Servlet.class
08:56:14,957 INFO  [TomcatDeployer] deploy, ctxPath=/webui,
warUrl=file:/Adempiere/jboss/server/adempiere/tmp/deploy/tmp35497webui.war/
08:56:15,077 INFO  [WebappClassLoader]
validateJarFile(/Adempiere/jboss/server/adempiere/./tmp/deploy/tmp35497webui.war/WEB-INF/lib/j2ee.jar)
- jar not loaded. See Servlet Spec 2.3, section 9.7.2. Offending class:
javax/servlet/Servlet.class
08:56:22,623 INFO  [EARDeployer] Started J2EE application:
file:/Adempiere/jboss/server/adempiere/deploy/adempiere.ear/
08:56:22,893 INFO  [Http11Protocol] Starting Coyote HTTP/1.1 on 
08:56:23,644 INFO  [ChannelSocket] JK: ajp13 listening on
mnit.com/111.14.88.21:8009
08:56:23,698 INFO  [JkMain] Jk running ID=0 time=0/105  config=null
08:56:23,761 INFO  [Http11Protocol] Starting Coyote HTTP/1.1 on
mnit.com-4443
08:56:23,829 INFO  [Server] JBoss (MX MicroKernel) [4.0.2 (build:
CVSTag=JBoss_4_0_2 date=200505022023)] Started in 2m:13s:123ms



ttmdev wrote:
> 
> It appears that one of your clients is setting the client identifier
> explicitly for its connection to the broker called, "wattle.broker".
> However, that client id has already been taken by another client that is
> already connected to the broker and thus the client id is being treated as
> an invalid duplicate id.
> 
> Joe
> Goto www.ttmsolutions.com for a free ActiveMQ user guide
> 
> 
> chif wrote:
>> 
>> Good Day,
>> I am running adempiere350`s and have configured it for replication.When i
>> start JBOSS it also starts activemq with no errors since i have embedded
>> it in jboss.I have created an order which i want to replicate to another
>> postgresql on our network.When i check for the order in Adempiere its
>> there but when i check for it in the two tables (activemq_msgs and
>> activemq_acks) created in postgresql where also i am running my adempiere
>> from these two tables (activemq_msgs and activemq_acks have no data in
>> them so i am stuck as to how i can push the data into these two tables
>> (activemq_msgs and activemq_acks) once i have created it in adempiere350.
>> Below is the log of my jboss server after starting it up:
>> 
>> 14:50:10,077 INFO  [STDOUT] javax.jms.InvalidClientIDException: Broker:
>> wattle.broker - Client: host1 already connected
>> 14:50:10,077 INFO  [STDOUT]     at
>> org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:180)
>> 14:50:10,077 INFO  [STDOUT]     at
>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:70)
>> 14:50:10,078 INFO  [STDOUT]     at
>> org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:70)
>> 14:50:10,106 INFO  [STDOUT]     at
>> org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:70)
>> 14:50:10,106 INFO  [STDOUT]     at
>> org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:83)
>> 14:50:10,107 INFO  [STDOUT]     at
>> org.apache.activemq.broker.AbstractConnection.processAddConnection(AbstractConnection.java:633)
>> 14:50:10,107 INFO  [STDOUT]     at
>> org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:83)
>> 14:50:10,107 INFO  [STDOUT]     at
>> org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:120)
>> 14:50:10,108 INFO  [STDOUT]     at
>> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
>> 14:50:10,108 INFO  [STDOUT]     at
>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
>> 14:50:10,108 INFO  [STDOUT]     at
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
>> 14:50:10,109 INFO  [STDOUT]     at
>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
>> 14:50:10,109 INFO  [STDOUT]     at
>> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:124)
>> 14:50:10,109 INFO  [STDOUT]     at
>> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
>> 14:50:10,109 INFO  [STDOUT]     at
>> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
>> 14:50:10,110 INFO  [STDOUT]     at
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
>> 14:50:10,110 INFO  [STDOUT]     at java.lang.Thread.run(Thread.java:595)
>> 
>> Is there anyting i need to configure in Adempiere so that messages can be
>> pushed.
>> Regards
>> admire
>> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Pushing-messages-from-Adempiere-to-ActiveMQ-tp16274455s2354p16395306.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message