| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Workflow.Runtime/ |
| H A D | WorkflowQueuingService.cs | 95 public void DeleteWorkflowQueue(IComparable queueName) in DeleteWorkflowQueue()
125 public bool Exists(IComparable queueName) in Exists()
141 public WorkflowQueue GetWorkflowQueue(IComparable queueName) in GetWorkflowQueue()
166 internal void EnqueueEvent(IComparable queueName, Object item) in EnqueueEvent()
199 internal bool SafeEnqueueEvent(IComparable queueName, Object item) in SafeEnqueueEvent()
234 internal object Peek(IComparable queueName) in Peek()
257 internal Object DequeueEvent(IComparable queueName) in DequeueEvent()
319 bool IsNestedListenersExist(IComparable queueName) in IsNestedListenersExist()
397 private EventQueueState GetEventQueueState(IComparable queueName) in GetEventQueueState()
587 private bool IsTransactionalQueue(IComparable queueName) in IsTransactionalQueue()
[all …]
|
| /dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Interfaces/Messaging/ |
| H A D | IMessageQueueClient.cs | 13 void Publish(string queueName, byte[] messageBytes); in Publish()
20 void Notify(string queueName, byte[] messageBytes); in Notify()
28 byte[] Get(string queueName, TimeSpan? timeOut); in Get()
35 byte[] GetAsync(string queueName); in GetAsync()
|
| /dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Common/Messaging/ |
| H A D | InMemoryMessageQueueClient.cs | 25 public void Publish(string queueName, byte[] messageBytes) in Publish()
30 public void Notify(string queueName, byte[] messageBytes) in Notify()
35 public byte[] GetAsync(string queueName) in GetAsync()
45 public byte[] Get(string queueName, TimeSpan? timeOut) in Get()
|
| H A D | MessageQueueClientFactory.cs | 27 public void PublishMessage<T>(string queueName, IMessage<T> message) in PublishMessage()
32 public void PublishMessage(string queueName, byte[] messageBytes) in PublishMessage()
49 public byte[] GetMessageAsync(string queueName) in GetMessageAsync()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Workflow.Activities/LocalService/ |
| H A D | MessageEventSubscriptionService.cs | 29 IComparable queueName; field in System.Workflow.Activities.MessageEventSubscription
36 public MessageEventSubscription(IComparable queueName, Guid instanceId) in MessageEventSubscription()
42 public MessageEventSubscription(IComparable queueName, Guid instanceId, Guid subscriptionId) in MessageEventSubscription()
48 …public MessageEventSubscription(IComparable queueName, Guid subscriptionId, Type interfaceType, St… in MessageEventSubscription()
54 …public MessageEventSubscription(IComparable queueName, Guid instanceId, Type interfaceType, String… in MessageEventSubscription()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/ |
| H A D | YarnScheduler.java | 67 public QueueInfo getQueueInfo(String queueName, boolean includeChildQueues, in getQueueInfo()
109 public Resource getMaximumResourceCapability(String queueName); in getMaximumResourceCapability()
192 QueueACL acl, String queueName); in checkAccess()
201 public List<ApplicationAttemptId> getAppsInQueue(String queueName); in getAppsInQueue()
240 void killAllAppsInQueue(String queueName) throws YarnException; in killAllAppsInQueue()
250 void removeQueue(String queueName) throws YarnException; in removeQueue()
|
| /dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Common/Messaging/Rcon/ |
| H A D | PacketProcessingClient.cs | 53 public void Publish(string queueName, byte[] messageBytes) in Publish()
63 public void Notify(string queueName, byte[] messageBytes) in Notify()
74 public byte[] Get(string queueName, TimeSpan? timeOut) in Get()
88 public byte[] GetAsync(string queueName) in GetAsync()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | QueueAclsInfo.java | 34 private String queueName; field in QueueAclsInfo
52 public QueueAclsInfo(String queueName, String[] operations) { in QueueAclsInfo()
61 protected void setQueueName(String queueName) { in setQueueName()
|
| H A D | JobQueueInfo.java | 40 private String queueName = ""; field in JobQueueInfo
56 public JobQueueInfo(String queueName, String schedulingInfo) { in JobQueueInfo()
67 public void setQueueName(String queueName) { in setQueueName()
|
| H A D | QueueManager.java | 146 public synchronized Queue getQueue(String queueName) { in getQueue()
164 public synchronized boolean hasAccess(String queueName, QueueACL qACL, in hasAccess()
192 synchronized boolean isRunning(String queueName) { in isRunning()
208 public synchronized void setSchedulerInfo(String queueName, in setSchedulerInfo()
224 public synchronized Object getSchedulerInfo(String queueName) { in getSchedulerInfo()
390 synchronized AccessControlList getQueueACL(String queueName, QueueACL qACL) { in getQueueACL()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/ |
| H A D | QueueAclsInfo.java | 40 private String queueName; field in QueueAclsInfo
57 public QueueAclsInfo(String queueName, String[] operations) { in QueueAclsInfo()
71 protected void setQueueName(String queueName) { in setQueueName()
|
| H A D | QueueInfo.java | 43 private String queueName = ""; field in QueueInfo
77 public QueueInfo(String queueName, String schedulingInfo) { in QueueInfo()
90 public QueueInfo(String queueName, String schedulingInfo, QueueState state, in QueueInfo()
102 protected void setQueueName(String queueName) { in setQueueName()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-rumen/src/main/java/org/apache/hadoop/tools/rumen/datatypes/ |
| H A D | QueueName.java | 25 private final String queueName; field in QueueName
27 public QueueName(String queueName) { in QueueName()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/ |
| H A D | SchedulerMetrics.java | 86 public abstract void trackQueue(String queueName); in trackQueue()
88 public void untrackQueue(String queueName) { in untrackQueue()
94 public boolean isTracked(String queueName) { in isTracked()
|
| H A D | FairSchedulerMetrics.java | 152 public void trackQueue(String queueName) { in trackQueue()
255 public void untrackQueue(String queueName) { in untrackQueue()
|
| /dports/java/springframework31/spring-framework-3.1.4.RELEASE/projects/org.springframework.jms/src/test/java/org/springframework/jms/ |
| H A D | StubQueue.java | 31 private String queueName = DEFAULT_QUEUE_NAME; field in StubQueue
37 public StubQueue(String queueName) { in StubQueue()
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.bundles/bundles/org.eclipse.equinox.cm/src/org/eclipse/equinox/internal/cm/ |
| H A D | SerializedTaskQueue.java | 26 private final String queueName; field in SerializedTaskQueue
28 public SerializedTaskQueue(String queueName) { in SerializedTaskQueue()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/ |
| H A D | ReservationSubmissionRequest.java | 41 ReservationDefinition reservationDefinition, String queueName) { in newInstance()
95 public abstract void setQueue(String queueName); in setQueue()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/ |
| H A D | QueueUserACLInfo.java | 43 public static QueueUserACLInfo newInstance(String queueName, in newInstance()
61 public abstract void setQueueName(String queueName); in setQueueName()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/ |
| H A D | CapacityScheduler.java | 540 String queueName = e.getKey(); in validateExistingQueues() local
565 String queueName = e.getKey(); in addNewQueues() local
638 public CSQueue getQueue(String queueName) { in getQueue()
708 ApplicationId applicationId, String queueName, String user) { in addApplicationOnRecovery()
774 String queueName, String user) { in addApplication()
923 String queueName = attempt.getQueue().getQueueName(); in doneApplicationAttempt() local
995 public QueueInfo getQueueInfo(String queueName, in getQueueInfo()
1230 String queueName = in handle() local
1484 QueueACL acl, String queueName) { in checkAccess()
1565 public synchronized void removeQueue(String queueName) in removeQueue()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/RabbitMQ.Client/src/client/messagepatterns/ |
| H A D | Subscription.cs | 167 public Subscription(IModel model, string queueName, string exchangeName, in Subscription()
180 public Subscription(IModel model, string queueName) in Subscription()
190 public Subscription(IModel model, string queueName, bool noAck, in Subscription()
202 public Subscription(IModel model, string queueName, bool noAck) in Subscription()
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/tombuildsstuff/giovanni/storage/2018-11-09/queue/messages/ |
| H A D | delete.go | 15 func (client Client) Delete(ctx context.Context, accountName, queueName, messageID, popReceipt stri… argument
55 func (client Client) DeletePreparer(ctx context.Context, accountName, queueName, messageID, popRece… argument
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/tombuildsstuff/giovanni/storage/2017-07-29/queue/messages/ |
| H A D | delete.go | 15 func (client Client) Delete(ctx context.Context, accountName, queueName, messageID, popReceipt stri… argument
55 func (client Client) DeletePreparer(ctx context.Context, accountName, queueName, messageID, popRece… argument
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/tombuildsstuff/giovanni/storage/2018-03-28/queue/messages/ |
| H A D | delete.go | 15 func (client Client) Delete(ctx context.Context, accountName, queueName, messageID, popReceipt stri… argument
55 func (client Client) DeletePreparer(ctx context.Context, accountName, queueName, messageID, popRece… argument
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/tombuildsstuff/giovanni/storage/2019-12-12/queue/messages/ |
| H A D | delete.go | 15 func (client Client) Delete(ctx context.Context, accountName, queueName, messageID, popReceipt stri… argument
55 func (client Client) DeletePreparer(ctx context.Context, accountName, queueName, messageID, popRece… argument
|