[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
