本文整理了Java中io.advantageous.qbit.queue.Queue.name
方法的一些代码示例,展示了Queue.name
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.name
方法的具体详情如下:
包路径:io.advantageous.qbit.queue.Queue
类名称:Queue
方法名:name
暂无
代码示例来源:origin: advantageous/qbit
/**
* name of queue
*
* @return name
*/
@Override
public String name() {
return queue.name();
}
代码示例来源:origin: io.advantageous.qbit/qbit-core
/**
* name of queue
*
* @return name
*/
@Override
public String name() {
return queue.name();
}
代码示例来源:origin: com.github.advantageous/qbit-core
/**
* name of queue
* @return name
*/
@Override
public String name() {
return queue.name();
}
代码示例来源:origin: advantageous/qbit
@Test
public void basicTest() {
sendQueue.send("hi");
sendQueue.flushSends();
final String item = receiveQueue.pollWait();
assertEquals("hi", item);
assertTrue(queue.hashCode() != 0);
assertTrue(queue.name() != null);
assertTrue(queue.size() == 0);
assertTrue(queue.toString() != null);
assertTrue(sendQueue.shouldBatch());
assertTrue(sendQueue.size() == 0);
assertTrue(sendQueue.name() != null);
assertTrue(sendQueue.hashCode() != 0);
assertTrue(receiveQueue.hashCode() != 0);
}
代码示例来源:origin: advantageous/qbit
@Before
public void setUp() throws Exception {
personQueue = JsonQueue.createMapQueue(String.class, Person.class, QueueBuilder.queueBuilder()
.setName("FOO").build());
personSendQueue = personQueue.sendQueue();
personReceiveQueue = personQueue.receiveQueue();
personSendQueue.shouldBatch();
personSendQueue.name();
personSendQueue.size();
personQueue.name();
personQueue.size();
}
代码示例来源:origin: advantageous/qbit
@Before
public void setUp() throws Exception {
personQueue = JsonQueue.createListQueue(Person.class, QueueBuilder.queueBuilder()
.setName("FOO").build());
personSendQueue = personQueue.sendQueue();
personReceiveQueue = personQueue.receiveQueue();
personSendQueue.shouldBatch();
personSendQueue.name();
personSendQueue.size();
personQueue.name();
personQueue.size();
}
代码示例来源:origin: advantageous/qbit
@Before
public void setUp() throws Exception {
personQueue = new JsonQueue<>(Person.class, QueueBuilder.queueBuilder()
.setName("FOO").build());
personSendQueue = personQueue.sendQueue();
personReceiveQueue = personQueue.receiveQueue();
personSendQueue.shouldBatch();
personSendQueue.name();
personSendQueue.size();
personQueue.name();
personQueue.size();
}
内容来源于网络,如有侵权,请联系作者删除!