|
@@ -306,7 +306,7 @@ public class DataServiceImpl implements IDataService {
|
|
//发送到耳标处理消息队列
|
|
//发送到耳标处理消息队列
|
|
//zj+330102002000003+13320241020004+87+0+10+154894+80+20240126174333+1.2#3.0#65535#10794+0+end
|
|
//zj+330102002000003+13320241020004+87+0+10+154894+80+20240126174333+1.2#3.0#65535#10794+0+end
|
|
int i = eartag.hashCode() %queues;
|
|
int i = eartag.hashCode() %queues;
|
|
- log.info("eartag.hashCode()"+eartag.hashCode());
|
|
|
|
|
|
+ i = i<0? -i:i ;
|
|
log.info("routinKey-->"+Const.ROUTING_KEY_ASK_EARTAG+i);
|
|
log.info("routinKey-->"+Const.ROUTING_KEY_ASK_EARTAG+i);
|
|
rabbitTemplate.convertAndSend(Const.EXCHANGE_ASK_EARTAG, Const.ROUTING_KEY_ASK_EARTAG+i, map);
|
|
rabbitTemplate.convertAndSend(Const.EXCHANGE_ASK_EARTAG, Const.ROUTING_KEY_ASK_EARTAG+i, map);
|
|
// } catch (AmqpTimeoutException e) {
|
|
// } catch (AmqpTimeoutException e) {
|