File tree Expand file tree Collapse file tree
activemq-unit-tests/src/test/java/org/apache/activemq Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -130,7 +130,7 @@ public void testDoNotReceiveExpiredMessage() throws Exception {
130130 producer .setTimeToLive (WAIT_TIME );
131131
132132 TextMessage message = session .createTextMessage ("Test message" );
133- producer .send (producerQueue , message );
133+ producer .send (message );
134134
135135 int count = getMessageCount (producerQueue , session );
136136 assertEquals (1 , count );
Original file line number Diff line number Diff line change @@ -466,12 +466,12 @@ public void testConsumeExpiredQueueAndDlq() throws Exception {
466466 String msgBody = new String (new byte [20 *1024 ]);
467467 for (int i = 0 ; i < data .length ; i ++) {
468468 Message message = session .createTextMessage (msgBody );
469- producerExpire .send (queue , message );
469+ producerExpire .send (message );
470470 }
471471
472472 for (int i = 0 ; i < data .length ; i ++) {
473473 Message message = session .createTextMessage (msgBody );
474- producerNormal .send (queue , message );
474+ producerNormal .send (message );
475475 }
476476
477477 ArrayList <Message > messages = new ArrayList <Message >();
You can’t perform that action at this time.
0 commit comments