JMS 池連線不支援同步接收

2021-07-12 00:15:09 字數 1051 閱讀 9136

使用org.apache.activemq.pool.pooledconnection連線,傳送訊息時不支援同步訊息接收:

/**

* 使用連線池

*/public void init() catch (exception e) }

// 消費訊息

public void receivemessage() throws jm***ception, exception

直接使用org.apache.activemq.activemqconnection,則可以接收同步訊息。

// 初始化

private void initialize() throws jm***ception, exception catch (exception e)

// 是生產和消費的乙個單執行緒上下文。會話用於建立訊息的生產者,消費者和訊息。會話提供了乙個事務性的上下文。

session = connection.createsession(false, session.auto_acknowledge); // 不支援事務

session temp = connection

.createsession(false, session.auto_acknowledge); // 不支援事務

destination = session.createqueue(subject);

// 會話建立訊息的生產者將訊息傳送到目的地

consumer = session.createconsumer(destination);

} // 消費訊息

public void receivemessage2() throws jm***ception, exception

解決該問題的要點:

在獲取連線後,要開始它!

connection.start();  //對於pooledconnection和activemqconnection均要求呼叫該方法。

Hive的on不支援非等值連線解決,不支援or

oracle select a.b.id asb id,b.class as b class from lpx test a a left outer join lpx test b b on a.id b.id and a.class b.class 連線條件的第二個是非等值的,不能照搬上面 hi...

支援測試驅動,不支援同步測試

測試驅動是一種開發的過程,採用單元測試的方式確定開發任務,指示開發進度,我覺得好。但是同步測試是一些專案中採用開發和測試同步進行的方法,這裡的測試,是功能測試了,是那種使用者的測試。不論開發人員是否提交版本,測試人員一通測試,告訴開發人員,你現在有1千多個bug,你要改啊。然後第二天,你提交了乙個版...

Hive 連線查詢操作(不支援IN查詢)

create external table if not exists a telno string,other string partitioned by day string row format delimited fields terminated by create external ta...