Package wt.queue

Class WtQueue

java.lang.Object
wt.fc._WTObject
wt.fc.WTObject
wt.fc._Item
wt.fc.Item
wt.queue._WtQueue
wt.queue.WtQueue
All Implemented Interfaces:
Externalizable, Serializable, wt.access._AccessControlled, wt.access._PolicyAccessControlled, wt.access._SecurityLabeled, AccessControlled, wt.access.PolicyAccessControlled, SecurityLabeled, wt.admin._DomainAdministered, DomainAdministered, wt.fc._NetFactor, wt.fc._ObjectMappable, wt.fc._Persistable, wt.fc.adminlock._AdministrativelyLockable, AdministrativelyLockable, NetFactor, ObjectMappable, Persistable, DisplayIdentification
Direct Known Subclasses:
wt.queue._ProcessingQueue, wt.queue._ScheduleQueue
@GenAsPersistable(superClass=Item.class,versions={6098226469578592873L,-3467512890522574741L},properties={@GeneratedProperty(name="name",type=java.lang.String.class,accessors=@PropertyAccessors(setAccess=PACKAGE,setExceptions={}),constraints=@PropertyConstraints(upperLimit=30,required=true),columnProperties=@ColumnProperties(unique=true)),@GeneratedProperty(name="executionHost",type=java.lang.String.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="enabled",type=boolean.class,initialValue="true",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="removeFailedEntires",type=boolean.class,initialValue="false",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="exceptionRetries",type=java.lang.Long.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="deleteWhenEmpty",type=boolean.class,initialValue="false",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="queueState",type=java.lang.String.class,supportedAPI=PRIVATE,accessors=@PropertyAccessors(setAccess=PACKAGE,setExceptions={})),@GeneratedProperty(name="lastStateSet",type=java.lang.String.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="suspendUntil",type=java.lang.Long.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="suspendDuration",type=java.lang.Long.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="totalEntries",type=java.lang.Integer.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="totalNotificationThreshold",type=java.lang.Integer.class,javaDoc="JMX notification threshold for total entries enqueued",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="waitingEntries",type=java.lang.Integer.class,accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="waitingNotificationThreshold",type=java.lang.Integer.class,javaDoc="JMX notification threshold for waiting ready entries enqueued",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="maxEntryExecutionTimeThreshold",type=java.lang.Long.class,javaDoc="Max duruation an entry can execute before triggering a JMX notification. Time is in seconds",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="randomAccessQueue",type=boolean.class,initialValue="false",accessors=@PropertyAccessors(setExceptions={})),@GeneratedProperty(name="stopWaitEntryCompletion",type=boolean.class,initialValue="false",supportedAPI=PRIVATE,javaDoc="Indicates this queue will wait as long as necessary for an executing entry to complete before stopping",accessors=@PropertyAccessors(getAccess=PACKAGE,setAccess=PACKAGE,setExceptions={})),@GeneratedProperty(name="stopDeleteRequest",type=boolean.class,initialValue="false",supportedAPI=PRIVATE,javaDoc="Indicates that the current stop request is part of a delete operation.This attribute is made available to the executing entry so that it can abort it\'s execution if appropriate",accessors=@PropertyAccessors(getAccess=PACKAGE,setAccess=PACKAGE,setExceptions={})),@GeneratedProperty(name="stopInterruptWaitEntryCompletion",type=boolean.class,initialValue="false",supportedAPI=PRIVATE,javaDoc="If this field is set it indicates that as part of a stop request -on a stopWaitEntryCompletion configured queue- an attempt to interrupt the thread will be part of the stop requests. This is future work, not currently implemented",accessors=@PropertyAccessors(getAccess=PACKAGE,setAccess=PACKAGE,setExceptions={}))},foreignKeys=@GeneratedForeignKey(name="QueueQueueLock",foreignKeyRole=@ForeignKeyRole(name="queueLock",type=wt.queue.QueueLock.class,cascade=true),myRole=@MyRole(name="queue",cardinality=ONE))) public abstract class WtQueue extends wt.queue._WtQueue


Supported API: true

Extendable: false
See Also:

  • Method Details

    • toString

      public String toString()
      Returns a string representation of the queue.

      Supported API: true
      Overrides:
      toString in class WTObject
      Returns:
      String