|
@@ -3,6 +3,9 @@ package com.tianbo.util.RabitMq; |
|
@@ -3,6 +3,9 @@ package com.tianbo.util.RabitMq; |
3
|
import com.rabbitmq.client.Connection;
|
3
|
import com.rabbitmq.client.Connection;
|
4
|
import com.rabbitmq.client.ConnectionFactory;
|
4
|
import com.rabbitmq.client.ConnectionFactory;
|
5
|
|
5
|
|
|
|
6
|
+import java.io.IOException;
|
|
|
7
|
+import java.util.concurrent.TimeoutException;
|
|
|
8
|
+
|
6
|
/**
|
9
|
/**
|
7
|
* 建立mq链接
|
10
|
* 建立mq链接
|
8
|
*/
|
11
|
*/
|
|
@@ -17,7 +20,7 @@ public class ConnectionUtil { |
|
@@ -17,7 +20,7 @@ public class ConnectionUtil { |
17
|
* @return 返回链接
|
20
|
* @return 返回链接
|
18
|
* @throws Exception
|
21
|
* @throws Exception
|
19
|
*/
|
22
|
*/
|
20
|
- public static Connection getConnection(String hostIp,int hostPort,String vHostName,String userName,String password) throws Exception {
|
23
|
+ public static Connection getConnection(String hostIp,int hostPort,String vHostName,String userName,String password) throws IOException, TimeoutException {
|
21
|
//定义连接工厂
|
24
|
//定义连接工厂
|
22
|
ConnectionFactory factory = new ConnectionFactory();
|
25
|
ConnectionFactory factory = new ConnectionFactory();
|
23
|
//设置服务地址
|
26
|
//设置服务地址
|