activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (AMQ-6971) 使用udp 协议时 当Active MQ server 在云服务器上,connection.start()会超时
Date Wed, 23 May 2018 13:15:00 GMT

     [ https://issues.apache.org/jira/browse/AMQ-6971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Timothy Bish closed AMQ-6971.
-----------------------------
    Resolution: Invalid

Please ask for help on the ActiveMQ Users mailing list.  In order to get the most help it
would be good to post the questions in English where possible. 

> 使用udp 协议时 当Active MQ server 在云服务器上,connection.start()会超时
> --------------------------------------------------------
>
>                 Key: AMQ-6971
>                 URL: https://issues.apache.org/jira/browse/AMQ-6971
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Connector
>    Affects Versions: 5.15.3
>         Environment: 消息队列服务: active mq==5.15.3 
> 运行环境:
> openjdk version "1.8.0_162"
> OpenJDK Runtime Environment (build 1.8.0_162-8u162-b12-0ubuntu0.16.04.2-b12)
> OpenJDK 64-Bit Server VM (build 25.162-b12, mixed mode)
>  
> java 客户端连接 jdk版本:jdk-10.0.1_windows-x64_bin.exe
> 运行环境:Windows10 64bit
>            Reporter: Jesse
>            Priority: Critical
>         Attachments: src.zip
>
>
> activemq.xml 文件:
> udp协议传输配置 <transportConnector name="udp" uri="udp://0.0.0.0:9010"/>
> java 客户端连接器code:
> import org.apache.activemq.ActiveMQConnectionFactory;
> import javax.jms.Connection;
> import javax.jms.Destination;
> import javax.jms.Session;
> public class MQConnector implements ErrorCode {
>  public static Destination destination;
>  public static Connection connection;
>  public static Session session;
>  //尝试连接队列服务若成功 生成一个MessageConsumer接口对应的类型,其中包含发送信息的方法;
>  public int connect(String url, String topic) throws Exception {
>  try {
>  // Create a ConnectionFactory
>  ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
>  // Create a Connection
>  connection = connectionFactory.createConnection();
>  connection.start();
>  // Create a Session
>  session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>  // Create the destination (Topic or Queue)
>  destination = session.createQueue(topic);
>  //返回错误值
>  return CONNECT_SUCCESS;
>  } catch (Exception e) {
>  //打印错误
>  System.out.println("Caught connect error:" + e);
>  e.printStackTrace();
>  return CONNECT_ERROR;
>  }
>  }
> }



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message