[jira] Assigned: (AMQ-1030) Pure master/slave not replicating messages
[ https://issues.apache.org/activemq/browse/AMQ-1030?page=all ] Rob Davies reassigned AMQ-1030: --- Assignee: Rob Davies > Pure master/slave not replicating messages > -- > > Key: AMQ-1030 > URL: https://issues.apache.org/activemq/browse/AMQ-1030 > Project: ActiveMQ > Issue Type: Bug > Components: Broker >Affects Versions: 4.1.0 > Environment: rhas4, sun jdk 1.5.0_08 >Reporter: Mike Atkin > Assigned To: Rob Davies > > Just did a fresh checkout of 4.1. The pure master/slave replication is not > forwarding messages received by master leading to lost messages if master > dies. Worked fine in rc-1. > Logs on both instances show all the usual "slave connected" messages. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] Assigned: (AMQ-1079) Slave Fail Error when Receiving message on a MasterSlave configuration
[ https://issues.apache.org/activemq/browse/AMQ-1079?page=all ] Rob Davies reassigned AMQ-1079: --- Assignee: Rob Davies > Slave Fail Error when Receiving message on a MasterSlave configuration > -- > > Key: AMQ-1079 > URL: https://issues.apache.org/activemq/browse/AMQ-1079 > Project: ActiveMQ > Issue Type: Bug > Components: Broker >Affects Versions: 4.2.0 > Environment: Windows XP, jdk1.5 >Reporter: Marlon Santos > Assigned To: Rob Davies > Fix For: 4.2.0 > > Attachments: ConsumerTool.java, MasterSlave.java, ProducerTool.java > > > A slave fail error is caught while receiving message from master broker on a > master slave configuration. > I included the java files that I used. Running this through xbean/xml config > also produces the same error. > SEVERE: Slave Failed > java.lang.AssertionError: Unsupported Method > at > org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71) > at > org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88) > at > org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88) > at > org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:49) > at > org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363) > at > org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:345) > at > org.apache.activemq.broker.ft.MasterBroker.acknowledge(MasterBroker.java:320) > at > org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:88) > at > org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:491) > at org.apache.activemq.command.MessageAck.visit(MessageAck.java:179) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:287) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65) > at > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133) > at > org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122) > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84) > at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137) > at java.lang.Thread.run(Thread.java:595) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] Resolved: (AMQ-1079) Slave Fail Error when Receiving message on a MasterSlave configuration
[ https://issues.apache.org/activemq/browse/AMQ-1079?page=all ] Rob Davies resolved AMQ-1079. - Resolution: Fixed this is fixed by SVN revision 490454 > Slave Fail Error when Receiving message on a MasterSlave configuration > -- > > Key: AMQ-1079 > URL: https://issues.apache.org/activemq/browse/AMQ-1079 > Project: ActiveMQ > Issue Type: Bug > Components: Broker >Affects Versions: 4.2.0 > Environment: Windows XP, jdk1.5 >Reporter: Marlon Santos > Assigned To: Rob Davies > Fix For: 4.2.0 > > Attachments: ConsumerTool.java, MasterSlave.java, ProducerTool.java > > > A slave fail error is caught while receiving message from master broker on a > master slave configuration. > I included the java files that I used. Running this through xbean/xml config > also produces the same error. > SEVERE: Slave Failed > java.lang.AssertionError: Unsupported Method > at > org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71) > at > org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88) > at > org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88) > at > org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:49) > at > org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363) > at > org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:345) > at > org.apache.activemq.broker.ft.MasterBroker.acknowledge(MasterBroker.java:320) > at > org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:88) > at > org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:491) > at org.apache.activemq.command.MessageAck.visit(MessageAck.java:179) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:287) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65) > at > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133) > at > org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122) > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84) > at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137) > at java.lang.Thread.run(Thread.java:595) -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] Resolved: (AMQ-1030) Pure master/slave not replicating messages
[ https://issues.apache.org/activemq/browse/AMQ-1030?page=all ] Rob Davies resolved AMQ-1030. - Resolution: Fixed this should be fixed by SVN revision 490454 > Pure master/slave not replicating messages > -- > > Key: AMQ-1030 > URL: https://issues.apache.org/activemq/browse/AMQ-1030 > Project: ActiveMQ > Issue Type: Bug > Components: Broker >Affects Versions: 4.1.0 > Environment: rhas4, sun jdk 1.5.0_08 >Reporter: Mike Atkin > Assigned To: Rob Davies > > Just did a fresh checkout of 4.1. The pure master/slave replication is not > forwarding messages received by master leading to lost messages if master > dies. Worked fine in rc-1. > Logs on both instances show all the usual "slave connected" messages. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] Created: (AMQ-1109) Start Broker SQL Exception
Start Broker SQL Exception --- Key: AMQ-1109 URL: https://issues.apache.org/activemq/browse/AMQ-1109 Project: ActiveMQ Issue Type: Bug Components: Broker Affects Versions: 4.1.0 Environment: Windows 2000, SQL 2005 Reporter: Artem Priority: Critical Attachments: activemq.log 1. Create DB for ActiveMQ 2. Start broker using jtds SQL 2005 driver. 3. Exception: 2006-12-27 11:08:48,796 [main ] INFO JDBCPersistenceAdapter - Database driver recognized: [jtds_type_4_jdbc_driver_for_ms_sql_server_and_sybase] 2006-12-27 11:08:48,983 [main ] INFO DefaultDatabaseLocker - Attempting to acquire the exclusive lock to become the Master broker 2006-12-27 11:08:48,983 [main ] ERROR DefaultDatabaseLocker - Failed to acquire lock: java.sql.SQLException: Line 1: FOR UPDATE clause allowed only for DECLARE CURSOR. java.sql.SQLException: Line 1: FOR UPDATE clause allowed only for DECLARE CURSOR. at net.sourceforge.jtds.jdbc.SQLDiagnostic.addDiagnostic(SQLDiagnostic.java:365) at net.sourceforge.jtds.jdbc.TdsCore.tdsErrorToken(TdsCore.java:2781) at net.sourceforge.jtds.jdbc.TdsCore.nextToken(TdsCore.java:2224) at net.sourceforge.jtds.jdbc.TdsCore.getMoreResults(TdsCore.java:628) at net.sourceforge.jtds.jdbc.JtdsStatement.processResults(JtdsStatement.java:525) at net.sourceforge.jtds.jdbc.JtdsStatement.executeSQL(JtdsStatement.java:487) at net.sourceforge.jtds.jdbc.JtdsPreparedStatement.execute(JtdsPreparedStatement.java:475) at org.apache.activemq.store.jdbc.DefaultDatabaseLocker.start(DefaultDatabaseLocker.java:59) at org.apache.activemq.store.jdbc.JDBCPersistenceAdapter.start(JDBCPersistenceAdapter.java:175) at org.apache.activemq.broker.BrokerService.createRegionBroker(BrokerService.java:1251) at org.apache.activemq.broker.BrokerService.createBroker(BrokerService.java:1209) at org.apache.activemq.broker.BrokerService.getBroker(BrokerService.java:508) at org.apache.activemq.broker.BrokerService.start(BrokerService.java:394) at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:47) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1062) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1029) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:420) at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:245) at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:141) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:242) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:156) at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:290) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:348) at org.apache.xbean.spring.context.ClassPathXmlApplicationContext.(ClassPathXmlApplicationContext.java:161) at org.apache.xbean.spring.context.ClassPathXmlApplicationContext.(ClassPathXmlApplicationContext.java:51) at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:41) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:57) at org.apache.activemq.console.command.StartCommand.startBroker(StartCommand.java:82) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:47) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:50) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:65) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:50) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:46) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.lang.reflect.Method.invoke(Unknown Source) at org.apache.activemq.console.Main.runTaskClass(Main.java:159) at org.apache.activemq.console.Main.main(Main.java:91) -- This message is automatically generated by JIRA. - If you th
[jira] Assigned: (AMQ-841) NullPointerException when using MasterConnector and specifying the broker name with space in it.
[ https://issues.apache.org/activemq/browse/AMQ-841?page=all ] Rob Davies reassigned AMQ-841: -- Assignee: Rob Davies > NullPointerException when using MasterConnector and specifying the broker > name with space in it. > > > Key: AMQ-841 > URL: https://issues.apache.org/activemq/browse/AMQ-841 > Project: ActiveMQ > Issue Type: Bug > Components: Broker >Affects Versions: 4.0.1 > Environment: Linux, jdk1.5.0_06 >Reporter: Richard Wafer > Assigned To: Rob Davies >Priority: Minor > > I've got a hard time trying to figure out why I got a null pointer trying to > use the Master/slave configuration for ActiveMQ. > Finnally by looking at the code I've saw the following: > In BrokerService.java > public void initializeMasterConnector(URI remoteURI) throws Exception { > ... > URI localURI = getVmConnectorURI(); > ... > } > public URI getVmConnectorURI() { > if (vmConnectorURI == null) { > try { > vmConnectorURI = new URI("vm://" + getBrokerName()); > } > catch (URISyntaxException e) { > } > } > return vmConnectorURI; > } > My problem is that I've specified a broker name with space in it "Slave > Broker". So I the new URI() here throw a URISyntaxException that was badly > absorb. And this leads to a null pointer at line:159 of TransportFactory.java. >String scheme = location.getScheme(); when location is null du to the > previous exception. > The link between the error and the cause was not clear at the first sigth. > A precondition on the setBrokerName could do the job. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira