本文整理汇总了Java中org.activiti.engine.impl.EventSubscriptionQueryImpl类的典型用法代码示例。如果您正苦于以下问题：Java EventSubscriptionQueryImpl类的具体用法？Java EventSubscriptionQueryImpl怎么用？Java EventSubscriptionQueryImpl使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
EventSubscriptionQueryImpl类属于org.activiti.engine.impl包，在下文中一共展示了EventSubscriptionQueryImpl类的17个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: cleanDb
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
protected void cleanDb() {
CommandExecutor commandExecutor = (CommandExecutor) processEngineConfiguration.getFlowable5CompatibilityHandler().getRawCommandExecutor();
commandExecutor.execute(new Command<Void>() {
public Void execute(CommandContext commandContext) {
final List<EventSubscriptionEntity> subscriptions = new EventSubscriptionQueryImpl(commandContext).list();
for (EventSubscriptionEntity eventSubscriptionEntity : subscriptions) {
eventSubscriptionEntity.delete();
}
return null;
}
});
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:14，代码来源:EventSubscriptionQueryTest.java
示例2: testMessageSubcription
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
/**
* 启动前检查对应的消息是否已注册到引擎
*/
@Deployment(resources = "chapter11/messageEvent/messageStartEvent.bpmn")
public void testMessageSubcription() throws Exception {
EventSubscriptionQueryImpl eventSubscriptionQuery = new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutor());
EventSubscriptionEntity subscriptionEntity = eventSubscriptionQuery.eventName("启动XXX流程").singleResult();
assertNotNull(subscriptionEntity);
}
开发者ID:shawn-gogh，项目名称:myjavacode，代码行数:10，代码来源:MessageStartEventTest.java
示例3: cleanDb
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
protected void cleanDb() {
processEngineConfiguration.getCommandExecutorTxRequired()
.execute(new Command<Void>() {
public Void execute(CommandContext commandContext) {
final List<EventSubscriptionEntity> subscriptions = new EventSubscriptionQueryImpl(commandContext).list();
for (EventSubscriptionEntity eventSubscriptionEntity : subscriptions) {
eventSubscriptionEntity.delete();
}
return null;
}
});
}
开发者ID:iotsap，项目名称:FiWare-Template-Handler，代码行数:14，代码来源:EventSubscriptionQueryTest.java
示例4: testDeploymentCreatesSubscriptions
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
public void testDeploymentCreatesSubscriptions() {
String deploymentId = repositoryService
.createDeployment()
.addClasspathResource("org/activiti/engine/test/bpmn/event/message/MessageStartEventTest.testSingleMessageStartEvent.bpmn20.xml")
.deploy()
.getId();
List<EventSubscriptionEntity> eventSubscriptions = new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutorTxRequired())
.list();
assertEquals(1, eventSubscriptions.size());
repositoryService.deleteDeployment(deploymentId);
}
开发者ID:iotsap，项目名称:FiWare-Template-Handler，代码行数:15，代码来源:MessageStartEventTest.java
示例5: cleanDb
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
protected void cleanDb() {
processEngineConfiguration.getCommandExecutor()
.execute(new Command<Void>() {
public Void execute(CommandContext commandContext) {
final List<EventSubscriptionEntity> subscriptions = new EventSubscriptionQueryImpl(commandContext).list();
for (EventSubscriptionEntity eventSubscriptionEntity : subscriptions) {
eventSubscriptionEntity.delete();
}
return null;
}
});
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:14，代码来源:EventSubscriptionQueryTest.java
示例6: testCatchSignalAndMessageAndTimer
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
@Deployment
public void testCatchSignalAndMessageAndTimer() {
runtimeService.startProcessInstanceByKey("catchSignal");
assertEquals(2, createEventSubscriptionQuery().count());
EventSubscriptionQueryImpl messageEventSubscriptionQuery = createEventSubscriptionQuery().eventType("message");
assertEquals(1, messageEventSubscriptionQuery.count());
assertEquals(1, createEventSubscriptionQuery().eventType("signal").count());
assertEquals(1, runtimeService.createProcessInstanceQuery().count());
assertEquals(1, managementService.createJobQuery().count());
// we can query for an execution with has both a signal AND message subscription
Execution execution = runtimeService.createExecutionQuery()
.messageEventSubscriptionName("newInvoice")
.signalEventSubscriptionName("alert")
.singleResult();
assertNotNull(execution);
ClockUtil.setCurrentTime(new Date(ClockUtil.getCurrentTime().getTime() +10000));
try {
EventSubscriptionEntity messageEventSubscription = messageEventSubscriptionQuery.singleResult();
runtimeService.messageEventReceived(messageEventSubscription.getEventName(), messageEventSubscription.getExecutionId());
assertEquals(0, createEventSubscriptionQuery().count());
assertEquals(1, runtimeService.createProcessInstanceQuery().count());
assertEquals(0, managementService.createJobQuery().count());
Task task = taskService.createTaskQuery()
.taskName("afterMessage")
.singleResult();
assertNotNull(task);
taskService.complete(task.getId());
}finally{
ClockUtil.setCurrentTime(new Date());
}
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:41，代码来源:EventBasedGatewayTest.java
示例7: testDeploymentCreatesSubscriptions
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
public void testDeploymentCreatesSubscriptions() {
String deploymentId = repositoryService
.createDeployment()
.addClasspathResource("org/activiti/engine/test/bpmn/event/message/MessageStartEventTest.testSingleMessageStartEvent.bpmn20.xml")
.deploy()
.getId();
List<EventSubscriptionEntity> eventSubscriptions = new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutor())
.list();
assertEquals(1, eventSubscriptions.size());
repositoryService.deleteDeployment(deploymentId);
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:15，代码来源:MessageStartEventTest.java
示例8: newEventSubscriptionQuery
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
protected EventSubscriptionQueryImpl newEventSubscriptionQuery() {
CommandExecutor commandExecutor = (CommandExecutor) processEngineConfiguration.getFlowable5CompatibilityHandler().getRawCommandExecutor();
return new EventSubscriptionQueryImpl(commandExecutor);
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:5，代码来源:EventSubscriptionQueryTest.java
示例9: findEventSubscriptionCountByQueryCriteria
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl) {
final String query = "selectEventSubscriptionCountByQueryCriteria";
return (Long) getDbSqlSession().selectOne(query, eventSubscriptionQueryImpl);
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:5，代码来源:EventSubscriptionEntityManager.java
示例10: findEventSubscriptionsByQueryCriteria
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<EventSubscriptionEntity> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl, Page page) {
final String query = "selectEventSubscriptionByQueryCriteria";
return getDbSqlSession().selectList(query, eventSubscriptionQueryImpl, page);
}
开发者ID:flowable，项目名称:flowable-engine，代码行数:6，代码来源:EventSubscriptionEntityManager.java
示例11: createEventSubscriptionQuery
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
/**
* 创建消息订阅查询对象（非公开API）
*/
private EventSubscriptionQueryImpl createEventSubscriptionQuery() {
return new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutor());
}
开发者ID:shawn-gogh，项目名称:myjavacode，代码行数:7，代码来源:SignalIntermediateEventTest.java
示例12: findEventSubscriptionCountByQueryCriteria
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl) {
final String query = "selectEventSubscriptionCountByQueryCriteria";
return (Long) getDbSqlSession().selectOne(query, eventSubscriptionQueryImpl);
}
开发者ID:iotsap，项目名称:FiWare-Template-Handler，代码行数:5，代码来源:EventSubscriptionManager.java
示例13: findEventSubscriptionsByQueryCriteria
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<EventSubscriptionEntity> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl, Page page) {
final String query = "selectEventSubscriptionByQueryCriteria";
return getDbSqlSession().selectList(query, eventSubscriptionQueryImpl, page);
}
开发者ID:iotsap，项目名称:FiWare-Template-Handler，代码行数:6，代码来源:EventSubscriptionManager.java
示例14: newEventSubscriptionQuery
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
protected EventSubscriptionQueryImpl newEventSubscriptionQuery() {
return new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutorTxRequired());
}
开发者ID:iotsap，项目名称:FiWare-Template-Handler，代码行数:4，代码来源:EventSubscriptionQueryTest.java
示例15: createEventSubscriptionQuery
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
private EventSubscriptionQueryImpl createEventSubscriptionQuery() {
return new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutorTxRequired());
}
开发者ID:iotsap，项目名称:FiWare-Template-Handler，代码行数:4，代码来源:EventBasedGatewayTest.java
示例16: newEventSubscriptionQuery
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
protected EventSubscriptionQueryImpl newEventSubscriptionQuery() {
return new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutor());
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:4，代码来源:EventSubscriptionQueryTest.java
示例17: createEventSubscriptionQuery
import org.activiti.engine.impl.EventSubscriptionQueryImpl; //导入依赖的package包/类
private EventSubscriptionQueryImpl createEventSubscriptionQuery() {
return new EventSubscriptionQueryImpl(processEngineConfiguration.getCommandExecutor());
}
开发者ID:springvelocity，项目名称:xbpm5，代码行数:4，代码来源:EventBasedGatewayTest.java
注：本文中的org.activiti.engine.impl.EventSubscriptionQueryImpl类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论