A B C D E F G H I K L M N O P R S T U V W

A

add(E) - Method in class com.bluejeans.common.utils.BulkOperationUtil

Add the given element to queue

addTargets(Map<String, Object>) - Method in class com.bluejeans.common.utils.URIInvoker

Add more targets.

addTargets(Object...) - Method in class com.bluejeans.common.utils.URIInvoker

Add more targets.

addTopicPartition(String) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

Add a topic-partition

allExtendedClassesOf(Class<?>) - Static method in class com.bluejeans.common.utils.MetaUtil

All classes that the given class extends

allFieldsOf(Class<?>) - Static method in class com.bluejeans.common.utils.MetaUtil

All fields that can be found on an object of the given class

allMethodsOf(Class<?>) - Static method in class com.bluejeans.common.utils.MetaUtil

All methods that can be invoked on an object of the given class

allSuperFieldsOf(Class<?>) - Static method in class com.bluejeans.common.utils.MetaUtil

All fields that can be found on an object's hierarchy other than itself of the given class

append(String) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Transfers the specified strings byte data, based on the charset, to the buffer starting at the current writerIndex and increases the writerIndex by the number of the transferred bytes (= bytes.length).

append(boolean) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Appends the given value as a string to the buffer.

append(int) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Appends the given value as a string to the buffer.

append(long) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Appends the given value as a string to the buffer.

append(Object) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Appends the given value as a string to the buffer.

append(CharSequence) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

append(CharSequence, int, int) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

append(char) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

appendError(Appendable, Throwable) - Method in class com.bluejeans.common.utils.URIInvoker

Builds error message from given exception.

appendRunLink(Appendable, String) - Method in class com.bluejeans.common.utils.URIInvoker

Appends the run value of the given input.

appendRunValue(Appendable, String) - Method in class com.bluejeans.common.utils.URIInvoker

Appends the run value of the given input.

appendString(String) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Appends a String and return this object.

appendValue(Appendable, String, boolean) - Method in class com.bluejeans.common.utils.URIInvoker

Appends the json object value of the supplied comma separated keys.

appendValue(Appendable, String, String, boolean) - Method in class com.bluejeans.common.utils.URIInvoker

Appends the json object value of the supplied comma separated keys.

appendValue(Appendable, Object) - Method in class com.bluejeans.common.utils.URIInvoker

Append the objects string representation to the given appendable.

assignFromHierarchy(Object) - Method in class com.bluejeans.common.utils.MetaUtil

For each field that the subclass has, if superclasses also have it, then fetch that value from hierarchy and set here.

availablePort(int, int) - Static method in class com.bluejeans.common.utils.MetaUtil

Get available server port from the given port inclusive, until the max count.

B

BigQueue<E> - Class in com.bluejeans.common.utils

Big queue extension

BigQueue(String, String, int) - Constructor for class com.bluejeans.common.utils.BigQueue

BigQueue(String, String) - Constructor for class com.bluejeans.common.utils.BigQueue

BigQueue(String, String, int, Class<E>) - Constructor for class com.bluejeans.common.utils.BigQueue

BigQueue(String, String, Class<E>) - Constructor for class com.bluejeans.common.utils.BigQueue

BulkOperationUtil<E> - Class in com.bluejeans.common.utils

Bulk operation utils for queuing elements and performing bulk operation on them at once, interval based

BulkOperationUtil.BulkOperation<E> - Interface in com.bluejeans.common.utils

The interface for the bulk operation

C

channelRead0(ChannelHandlerContext, FullHttpRequest) - Method in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

CHUNK_LENGTH - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

The append chunk size.

classNameObjectMap(Object...) - Static method in class com.bluejeans.common.utils.MetaUtil

Returns a map containing the object's class name as key with the object itself as value.

clone() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

close() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

close() - Method in class com.bluejeans.common.utils.kafka.ObjectDeserializer

com.bluejeans.common.utils - package com.bluejeans.common.utils

com.bluejeans.common.utils.kafka - package com.bluejeans.common.utils.kafka

com.bluejeans.common.utils.theon - package com.bluejeans.common.utils.theon

configure(Map<String, ?>, boolean) - Method in class com.bluejeans.common.utils.kafka.ObjectDeserializer

consumeFromPartition(String, String, KafkaRecordProcessor<K, V>...) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

contains(CharSequence) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Returns true if and only if this string representation of the buffer contains the specified sequence of char values.

contextDestroyed(ServletContextEvent) - Method in class com.bluejeans.common.utils.InvokerServletListener

contextInitialized(ServletContextEvent) - Method in class com.bluejeans.common.utils.InvokerServletListener

convert(Object) - Method in class com.bluejeans.common.utils.URIInvoker

Convert an object to string.

copyFields(Object, Object) - Method in class com.bluejeans.common.utils.MetaUtil

For each field that the destination has, if source also have it, then fetch that value from source and set in destination.

create(int, int, String, String, long, BulkOperationUtil.BulkOperation<E>, int, int, int) - Static method in class com.bluejeans.common.utils.BulkOperationUtil

Create based on parameters

create(int, int, BulkOperationUtil.BulkOperation<E>, int, int, int) - Static method in class com.bluejeans.common.utils.BulkOperationUtil

Create based on parameters

create(int, int, BulkOperationUtil.BulkOperation<E>) - Static method in class com.bluejeans.common.utils.BulkOperationUtil

Create based on parameters

createMap(String, Object) - Static method in class com.bluejeans.common.utils.MetaUtil

Returns a new map which has single entry with the given key and value.

createParamMap(Object...) - Static method in class com.bluejeans.common.utils.MetaUtil

Create a params map from given varargs.

createPropsMap(String...) - Static method in class com.bluejeans.common.utils.MetaUtil

Create a property map from given varargs.

D

defaultBuffer - Variable in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

The default buffer.

deserialize(String, byte[]) - Method in class com.bluejeans.common.utils.kafka.ObjectDeserializer

destroy() - Method in class com.bluejeans.common.utils.InvokerSpringBean

Destroy

destroy() - Method in class com.bluejeans.common.utils.theon.TheonClient

Stop the bulk util and close the http client

disableSslCertificates() - Static method in class com.bluejeans.common.utils.MetaUtil

Disables SSL certificates checks

doBulk(Collection<E>) - Method in interface com.bluejeans.common.utils.BulkOperationUtil.BulkOperation

Specify what to do with the bulk collection

doBulk() - Method in class com.bluejeans.common.utils.BulkOperationUtil

Do the bulk operation.

drainTo(Collection<? super E>, int) - Method in class com.bluejeans.common.utils.BigQueue

E

element(byte[]) - Method in class com.bluejeans.common.utils.BigQueue

EnumCounter<E extends Enum<E>> - Class in com.bluejeans.common.utils

Maintains all the counts related to given enum.

EnumCounter(Class<E>) - Constructor for class com.bluejeans.common.utils.EnumCounter

initializes all the counts.

EnumCounter.EventCountMap - Class in com.bluejeans.common.utils

Map for maintaining enum counts.

EventCountMap(Class<E>) - Constructor for class com.bluejeans.common.utils.EnumCounter.EventCountMap

exceptionCaught(ChannelHandlerContext, Throwable) - Method in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

exec(String) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command.

exec(String, String[], File) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command.

execOut(String, String) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command sends the given input line and returns the output of it.

execOut(String, String[], File, String, boolean) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command sends the given input line and returns the output of it.

execOut(String) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command and returns the output of it.

execOut(String, String[], File, boolean) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command and returns the output of it.

F

fieldDataMap(Object, boolean, String, List<Class<?>>) - Static method in class com.bluejeans.common.utils.MetaUtil

Get the map of all the return values of all the methods starting with given prefix with the given return types of the given bean.

findFirstField(Class<?>, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the first field by this name or null if not found.

findFirstFieldByType(Class<?>, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the first field by its type name or null if not found.

findFirstMethod(Class<?>, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the first method by this name or null if not found.

findFirstMethod(Class<?>, String, int) - Static method in class com.bluejeans.common.utils.MetaUtil

Find first method matching name and no.

findFirstMethodEndsWithAndReturns(Class<?>, String, Class<?>) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the first method ending by this name and having this return type or null if not found.

findFirstMethodStartsWith(Class<?>, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the first method starting by this name or null if not found.

findFirstSuperField(Class<?>, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the first super field by this name or null if not found.

findMethod(Class<?>, String, int) - Method in class com.bluejeans.common.utils.URIInvoker

Find first method matching name and no.

findSetter(Class<?>, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Finds the setter method for the property or null if not found.

flush() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

G

get(Object) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

getAutoCommitIntervalMillis() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getBatchSize() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBigQueue() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBigQueueTimer() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBigQueueTimerInterval() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBigQueueTimerInterval() - Method in class com.bluejeans.common.utils.theon.TheonClient

getBulkExecutor() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBulkExecutorQueueCapacity() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBulkExecutorSize() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBulkMessageSize() - Method in class com.bluejeans.common.utils.theon.TheonClient

getBulkOperation() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBulkOperation() - Method in class com.bluejeans.common.utils.theon.TheonClient

getBulkOperationUtil() - Method in class com.bluejeans.common.utils.theon.TheonClient

getBulkPollInterval() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getBulkPollIntervalSecs() - Method in class com.bluejeans.common.utils.theon.TheonClient

getBulkRunnable() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getByteBuf() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

getChannelInitializer() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

getCharset() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

getChildGroup() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

getClassLoadingMXBean() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the classloading MX bean.

getCompilationMXBean() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the compilation MX bean.

getConsumer() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getContext() - Method in class com.bluejeans.common.utils.InvokerSpringBean

getContextPrefix() - Method in class com.bluejeans.common.utils.InvokerService

getContextPrefix() - Method in class com.bluejeans.common.utils.InvokerSpringBean

getConvertUtil() - Method in class com.bluejeans.common.utils.URIInvoker

getDefaultKey() - Method in class com.bluejeans.common.utils.theon.TheonClient

getDoer() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getEncoding() - Method in class com.bluejeans.common.utils.kafka.ObjectDeserializer

getEnum(String) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

get the enum for the given string

getEventCounts() - Method in class com.bluejeans.common.utils.EnumCounter

getExtjsResourcePrefix() - Method in class com.bluejeans.common.utils.InvokerService

getExtjsResourcePrefix() - Method in class com.bluejeans.common.utils.InvokerSpringBean

getExtraProps() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getGroupId() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getGson() - Method in class com.bluejeans.common.utils.InvokerService

getHandler() - Method in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpInitializer

getHttpClient() - Method in class com.bluejeans.common.utils.theon.TheonClient

getHttpConnPoolSize() - Method in class com.bluejeans.common.utils.theon.TheonClient

getInvoker() - Method in class com.bluejeans.common.utils.InvokerService

getInvokerjsResourcePrefix() - Method in class com.bluejeans.common.utils.InvokerService

getInvokerjsResourcePrefix() - Method in class com.bluejeans.common.utils.InvokerSpringBean

getJsEngine() - Method in class com.bluejeans.common.utils.URIInvoker

getKey() - Method in class com.bluejeans.common.utils.theon.TheonClient.TheonMessage

getKeyDeserializer() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getMaxCapacity() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

getMaxPostEntitySize() - Method in class com.bluejeans.common.utils.theon.TheonClient

getMemoryMXBean() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the memory MX bean.

getMessage() - Method in class com.bluejeans.common.utils.theon.TheonClient.TheonMessage

getMethodName() - Method in class com.bluejeans.common.utils.kafka.ObjectDeserializer

getMinBatchSize() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getN(Object) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

Get the value, if null reset it.

getNanoServer() - Method in class com.bluejeans.common.utils.InvokerService

getNettyServerRef() - Method in class com.bluejeans.common.utils.InvokerService

getO(Object) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

Get the value, the old way.

getObjectClass() - Method in class com.bluejeans.common.utils.kafka.ObjectDeserializer

getOfferFailCount() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getOsMXBean() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the operating system MX bean.

getParallelBulkOperationUtil() - Method in class com.bluejeans.common.utils.theon.TheonClient

getParentGroup() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

getPassword() - Method in class com.bluejeans.common.utils.theon.TheonClient

getPollTimeout() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getPort() - Method in class com.bluejeans.common.utils.InvokerService

getPort() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

getProcessId() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the process id.

getProcessMap() - Method in class com.bluejeans.common.utils.SystemInfo

getQueue() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getQueueCapacity() - Method in class com.bluejeans.common.utils.theon.TheonClient

getQueueDir() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getQueueDir() - Method in class com.bluejeans.common.utils.theon.TheonClient

getQueueName() - Method in class com.bluejeans.common.utils.BulkOperationUtil

getQueueName() - Method in class com.bluejeans.common.utils.theon.TheonClient

getQueueSize() - Method in class com.bluejeans.common.utils.BulkOperationUtil

Get the queue size

getRecordProcessors() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getResourceAsString(String) - Static method in class com.bluejeans.common.utils.MetaUtil

Get the resource as string.

getRunning() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getRuntime() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the JVM runtime.

getRuntimeMXBean() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the runtime MX bean.

getS(Object) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

Get synchronized.

getSecEventCounts() - Method in class com.bluejeans.common.utils.EnumCounter

getServer() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getServerBootstrap() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

getServerChannel() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

getService() - Method in class com.bluejeans.common.utils.InvokerSpringBean

getSessionTimeoutMillis() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getStatusCounter() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getTargetMap() - Method in class com.bluejeans.common.utils.URIInvoker

getTheonCounter() - Method in class com.bluejeans.common.utils.theon.TheonClient

getTheonUri() - Method in class com.bluejeans.common.utils.theon.TheonClient

getTheonUrl() - Method in class com.bluejeans.common.utils.theon.TheonClient

getThreadMXBean() - Method in class com.bluejeans.common.utils.SystemInfo

Returns the thread MX bean.

getTitle() - Method in class com.bluejeans.common.utils.InvokerSpringBean

getTopic() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

getTopic() - Method in class com.bluejeans.common.utils.theon.TheonClient.TheonMessage

getUsername() - Method in class com.bluejeans.common.utils.theon.TheonClient

getValue(String) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

get the count of given enum stirng

getValue(String) - Method in class com.bluejeans.common.utils.EnumCounter

get the event count

getValue() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

The string value of the byte buf.

getValueDeserializer() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

H

hash(String) - Static method in class com.bluejeans.common.utils.MetaUtil

Computes a long hash for this string.

I

incrementEventCount(E) - Method in class com.bluejeans.common.utils.EnumCounter

Increments an event count.

incrementEventCount(E, int) - Method in class com.bluejeans.common.utils.EnumCounter

Increments an event count by given value.

init() - Method in class com.bluejeans.common.utils.InvokerSpringBean

Initialize.

init() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

init() - Method in class com.bluejeans.common.utils.theon.TheonClient

Initialized the bulk util and the http client

initChannel(SocketChannel) - Method in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpInitializer

initServerBootstrap() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

Init only server bootstrap

initWithPort(int) - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

The port to bind to.

instance() - Static method in class com.bluejeans.common.utils.InvokerService

Returns the singleton instance.

invokeNestedMethod(String, String) - Method in class com.bluejeans.common.utils.URIInvoker

Invoke a nested method/property on target object.

invokeNestedMethod(Object, String) - Method in class com.bluejeans.common.utils.URIInvoker

Invoke a nested method/property on target object.

Invoker() - Constructor for class com.bluejeans.common.utils.InvokerMBean.Invoker

Registers this as MBean.

InvokerInfoBuffer() - Constructor for class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Creates default info buffer with unpooled heap buffer and UTF8 charset.

InvokerInfoBuffer(int) - Constructor for class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Creates default info buffer with unpooled heap buffer and UTF8 charset.

InvokerInfoBuffer(ByteBuf, Charset) - Constructor for class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

InvokerMBean - Interface in com.bluejeans.common.utils

Invoker MBean

InvokerMBean.Invoker - Class in com.bluejeans.common.utils

The invoker basic implementation.

InvokerServerHttpHandler() - Constructor for class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

InvokerServerHttpInitializer() - Constructor for class com.bluejeans.common.utils.InvokerService.InvokerServerHttpInitializer

InvokerService - Class in com.bluejeans.common.utils

Invoker Service

InvokerService() - Constructor for class com.bluejeans.common.utils.InvokerService

the default one

InvokerService(int, Object...) - Constructor for class com.bluejeans.common.utils.InvokerService

InvokerService(int, Map<String, Object>) - Constructor for class com.bluejeans.common.utils.InvokerService

InvokerService.InvokerInfoBuffer - Class in com.bluejeans.common.utils

Info buffer.

InvokerService.InvokerServerHttpHandler - Class in com.bluejeans.common.utils

Invoker server handler.

InvokerService.InvokerServerHttpInitializer - Class in com.bluejeans.common.utils

Invoker server HTTP initializer.

InvokerService.NettyServerRef<T extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>> - Class in com.bluejeans.common.utils

Netty Server reference.

InvokerServletListener - Class in com.bluejeans.common.utils

Servlet context listener for Invoker service.

InvokerServletListener() - Constructor for class com.bluejeans.common.utils.InvokerServletListener

InvokerSpringBean - Class in com.bluejeans.common.utils

Spring bean to start invoker service with application context as target.

InvokerSpringBean() - Constructor for class com.bluejeans.common.utils.InvokerSpringBean

The default one

InvokerSpringBean(int, Object...) - Constructor for class com.bluejeans.common.utils.InvokerSpringBean

With port and targets

isAutoCreateValue() - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

isCommitSyncEnabled() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

isEnableAutoCommit() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

isFileBased() - Method in class com.bluejeans.common.utils.BulkOperationUtil

isFileBasedQueue() - Method in class com.bluejeans.common.utils.theon.TheonClient

isGzipEnabled() - Method in class com.bluejeans.common.utils.theon.TheonClient

isInitialized() - Method in class com.bluejeans.common.utils.theon.TheonClient

isParallel() - Method in class com.bluejeans.common.utils.BulkOperationUtil

isParallelEnabled() - Method in class com.bluejeans.common.utils.theon.TheonClient

isPeekEnabled() - Method in class com.bluejeans.common.utils.BulkOperationUtil

isPeekEnabled() - Method in class com.bluejeans.common.utils.theon.TheonClient

isPostPerKey() - Method in class com.bluejeans.common.utils.theon.TheonClient

isRunning() - Method in class com.bluejeans.common.utils.InvokerService

isSpecificPartitions() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

isStopped() - Method in class com.bluejeans.common.utils.BulkOperationUtil

isWaitEnabled() - Method in class com.bluejeans.common.utils.BulkOperationUtil

K

KafkaRecordProcessor<K,V> - Interface in com.bluejeans.common.utils.kafka

Consumer record processor

L

LINE_SEPARATOR - Static variable in class com.bluejeans.common.utils.SystemInfo

The current OS line separator.

listTopicNames() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

List all topic names

M

main(String[]) - Static method in class com.bluejeans.common.utils.InvokerService

The starter for command line.

MAIN_PREFIX - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

The main uri prefix.

mainHtmlBuffer - Variable in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

The default buffer.

MAX_CAPACITY - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

The maximum capacity of the buffer.

MetaUtil - Class in com.bluejeans.common.utils

Meta utility.

MetaUtil() - Constructor for class com.bluejeans.common.utils.MetaUtil

METHOD_PREFIX - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

The method uri prefix.

MIN_CAPACITY - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

The minimum capacity of the buffer.

N

NettyServerRef(ServerBootstrap, T, EventLoopGroup, EventLoopGroup, Class<? extends ServerChannel>) - Constructor for class com.bluejeans.common.utils.InvokerService.NettyServerRef

O

ObjectDeserializer<T> - Class in com.bluejeans.common.utils.kafka

Any object Deserializer

ObjectDeserializer() - Constructor for class com.bluejeans.common.utils.kafka.ObjectDeserializer

ObjectSizeCalculator - Class in com.bluejeans.common.utils

Object Size calculator

ObjectSizeCalculator() - Constructor for class com.bluejeans.common.utils.ObjectSizeCalculator

P

peekTo(Collection<? super E>, int) - Method in class com.bluejeans.common.utils.BigQueue

pop() - Method in class com.bluejeans.common.utils.BigQueue

postMessage(String, String, E) - Method in class com.bluejeans.common.utils.theon.TheonClient

Add the message to the bulk queue

postMessage(String, String, E, boolean) - Method in class com.bluejeans.common.utils.theon.TheonClient

Add the message to the bulk queue

postMessageNow(String, String, E) - Method in class com.bluejeans.common.utils.theon.TheonClient

Post the given message now

postMessagesNow(String, String, Map<String, List<E>>) - Method in class com.bluejeans.common.utils.theon.TheonClient

Post the given list of messages now

postMessagesNow(String, String, E...) - Method in class com.bluejeans.common.utils.theon.TheonClient

Post all the given messages now for the given key

postMessagesNow(String, String, List<E>) - Method in class com.bluejeans.common.utils.theon.TheonClient

Post the given list of messages now for specific key

preInit() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

printThis(String, String...) - Method in class com.bluejeans.common.utils.InvokerMBean.Invoker

printThis(String, String...) - Method in interface com.bluejeans.common.utils.InvokerMBean

Print the value by running any on this.

PROCESS_ID - Static variable in class com.bluejeans.common.utils.SystemInfo

The JVM process id.

processKafkaRecord(ConsumerRecord<K, V>) - Method in interface com.bluejeans.common.utils.kafka.KafkaRecordProcessor

processRequest(FullHttpRequest) - Method in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

Process the given URI and return the info buffer for its response.

processRequest(FullHttpRequest, String[]) - Method in class com.bluejeans.common.utils.InvokerService

Process the given request and URI spec.

push(E) - Method in class com.bluejeans.common.utils.BigQueue

R

readableSize(long) - Static method in class com.bluejeans.common.utils.URIInvoker

Returns a readable size representation of the given bytes size.

readLine(String) - Method in class com.bluejeans.common.utils.SystemInfo

Reads a line from the command stream.

readLine(Process) - Method in class com.bluejeans.common.utils.SystemInfo

Reads a line from the command stream.

readLines(String) - Method in class com.bluejeans.common.utils.SystemInfo

Reads all the output lines from the command stream.

readLines(Process) - Method in class com.bluejeans.common.utils.SystemInfo

Reads all the output lines from the command stream.

reassignTopic(String) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

Re assign the topics

registerAsMBean(Object) - Static method in class com.bluejeans.common.utils.MetaUtil

Register the instance as MBean.

registerAsMBean(Object, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Register the instance as MBean with given name.

removeTopicPartition(String) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

Add a topic-partition

reset() - Method in class com.bluejeans.common.utils.EnumCounter

Resets all the counts to zeros.

reset() - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

Resets the indexes.

resetJsEngine() - Method in class com.bluejeans.common.utils.URIInvoker

Reset the JS Engine.

resetJsEngine(String) - Method in class com.bluejeans.common.utils.URIInvoker

Reset the JS Engine with given one.

resetSecEventCounts() - Method in class com.bluejeans.common.utils.EnumCounter

Resets the secondary event counts.

run(String) - Method in class com.bluejeans.common.utils.SystemInfo

Executes a command and returns the output of it / exception if any

run(String) - Method in class com.bluejeans.common.utils.URIInvoker

Evaluates the given script.

RUN_PREFIX - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

The run uri prefix.

runCommandFromStream(InputStream, String, String, boolean) - Static method in class com.bluejeans.common.utils.SystemInfo

Runs a command from its stream data.

runLink(String) - Method in class com.bluejeans.common.utils.URIInvoker

Evaluates the content of the js from given link.

runNestedMethod(Object, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Run the nested method on the target object.

runNestedMethodsSilently(Object, String) - Static method in class com.bluejeans.common.utils.MetaUtil

Run the nested methods silently on the target object.

runThis(String, String...) - Method in class com.bluejeans.common.utils.InvokerMBean.Invoker

runThis(String, String...) - Method in interface com.bluejeans.common.utils.InvokerMBean

Run any on this.

S

setApplicationContext(ApplicationContext) - Method in class com.bluejeans.common.utils.InvokerSpringBean

setAutoCommitIntervalMillis(int) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setAutoCreateValue(boolean) - Method in class com.bluejeans.common.utils.EnumCounter.EventCountMap

setBatchSize(int) - Method in class com.bluejeans.common.utils.BulkOperationUtil

setBigQueueTimerInterval(long) - Method in class com.bluejeans.common.utils.theon.TheonClient

setBulkMessageSize(int) - Method in class com.bluejeans.common.utils.theon.TheonClient

setBulkPollIntervalSecs(int) - Method in class com.bluejeans.common.utils.theon.TheonClient

setCommitSyncEnabled(boolean) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setContextPrefix(String) - Method in class com.bluejeans.common.utils.InvokerService

setContextPrefix(String) - Method in class com.bluejeans.common.utils.InvokerSpringBean

setDefaultKey(String) - Method in class com.bluejeans.common.utils.theon.TheonClient

setEnableAutoCommit(boolean) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setExtjsResourcePrefix(String) - Method in class com.bluejeans.common.utils.InvokerService

setExtjsResourcePrefix(String) - Method in class com.bluejeans.common.utils.InvokerSpringBean

setExtraProps(Map<String, Object>) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setFileBased(boolean) - Method in class com.bluejeans.common.utils.BulkOperationUtil

setFileBasedQueue(boolean) - Method in class com.bluejeans.common.utils.theon.TheonClient

setGroupId(String) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setGzipEnabled(boolean) - Method in class com.bluejeans.common.utils.theon.TheonClient

setHttpConnPoolSize(int) - Method in class com.bluejeans.common.utils.theon.TheonClient

setInvokerjsResourcePrefix(String) - Method in class com.bluejeans.common.utils.InvokerService

setInvokerjsResourcePrefix(String) - Method in class com.bluejeans.common.utils.InvokerSpringBean

setKeyDeserializer(Deserializer<K>) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setMaxPostEntitySize(int) - Method in class com.bluejeans.common.utils.theon.TheonClient

setMinBatchSize(int) - Method in class com.bluejeans.common.utils.BulkOperationUtil

setParallel(boolean) - Method in class com.bluejeans.common.utils.BulkOperationUtil

setParallelEnabled(boolean) - Method in class com.bluejeans.common.utils.theon.TheonClient

setPassword(String) - Method in class com.bluejeans.common.utils.theon.TheonClient

setPeekEnabled(boolean) - Method in class com.bluejeans.common.utils.BulkOperationUtil

setPeekEnabled(boolean) - Method in class com.bluejeans.common.utils.theon.TheonClient

setPollTimeout(int) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setPort(int) - Method in class com.bluejeans.common.utils.InvokerService

setPostPerKey(boolean) - Method in class com.bluejeans.common.utils.theon.TheonClient

setPropertyIfExists(Object, String, Object) - Static method in class com.bluejeans.common.utils.MetaUtil

Sets the given property if exists with the given value.

setQueueCapacity(int) - Method in class com.bluejeans.common.utils.theon.TheonClient

setQueueDir(String) - Method in class com.bluejeans.common.utils.theon.TheonClient

setQueueName(String) - Method in class com.bluejeans.common.utils.theon.TheonClient

setRecordProcessors(List<KafkaRecordProcessor<K, V>>) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setServer(String) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setSessionTimeoutMillis(int) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setSpecificPartitions(boolean) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setTarget(String, Object) - Method in class com.bluejeans.common.utils.URIInvoker

Set the target with name.

setTarget(Object) - Method in class com.bluejeans.common.utils.URIInvoker

Set the target.

setTheonUrl(String) - Method in class com.bluejeans.common.utils.theon.TheonClient

setTitle(String) - Method in class com.bluejeans.common.utils.InvokerSpringBean

setTopic(String) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setUsername(String) - Method in class com.bluejeans.common.utils.theon.TheonClient

setValueDeserializer(Deserializer<V>) - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

setWaitEnabled(boolean) - Method in class com.bluejeans.common.utils.BulkOperationUtil

shuffleArray(Object) - Static method in class com.bluejeans.common.utils.MetaUtil

Shuffles the given array, if it is array.

shutdown() - Method in class com.bluejeans.common.utils.InvokerService.NettyServerRef

Shutdown this server ref.

shutdown() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

SIMPLE_RETURN_TYPE_LIST - Static variable in class com.bluejeans.common.utils.MetaUtil

The simple return type list

simpleFieldDataMap(Object, boolean) - Static method in class com.bluejeans.common.utils.MetaUtil

Get the map of all the return values of all the methods with no arguments with simple return types of the given bean.

SimpleKafkaConsumer<K,V> - Class in com.bluejeans.common.utils.kafka

Kafka String based consumer

SimpleKafkaConsumer() - Constructor for class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

SimpleKafkaConsumer.Status - Enum in com.bluejeans.common.utils.kafka

SIZE_STEPS - Static variable in class com.bluejeans.common.utils.URIInvoker

The size step suffixes

sizeOf(Object) - Static method in class com.bluejeans.common.utils.ObjectSizeCalculator

calculates the size of given object

sizeof(Object) - Static method in class com.bluejeans.common.utils.URIInvoker

Calculates the size of the the given object.

sizeofProperty(String, String) - Method in class com.bluejeans.common.utils.URIInvoker

Calculates the size of the object represented by the property over the target.

SLASH - Static variable in class com.bluejeans.common.utils.InvokerService

start() - Method in class com.bluejeans.common.utils.InvokerService

Start

start(String) - Method in class com.bluejeans.common.utils.InvokerService

Start with context.

start(Object...) - Static method in class com.bluejeans.common.utils.InvokerService

Start the singleton instance with given targets.

start() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

stop() - Method in class com.bluejeans.common.utils.BulkOperationUtil

Stop the utility and operate on any remaining elements in queue.

stop() - Method in class com.bluejeans.common.utils.InvokerService

Stop.

SuperTester - Class in com.bluejeans.common.utils

The tester class for testing all the Get and Set methods in the classes in the given package / for the list of specified objects.

SuperTester(Object[]) - Constructor for class com.bluejeans.common.utils.SuperTester

Constructs the Tester with supplied list of objects.

SuperTester(String, String[]) - Constructor for class com.bluejeans.common.utils.SuperTester

Constructs the Tester with supplied package and class names.

SuperTester(Class<?>...) - Constructor for class com.bluejeans.common.utils.SuperTester

Constructs the Tester with supplied package and class names.

SystemInfo - Class in com.bluejeans.common.utils

JVM and OS info

SystemInfo() - Constructor for class com.bluejeans.common.utils.SystemInfo

T

testAll() - Method in class com.bluejeans.common.utils.SuperTester

Test all.

testAll(String) - Static method in class com.bluejeans.common.utils.SuperTester

Blindly tests all the objects created from the classes from the given package.

testGetters() - Method in class com.bluejeans.common.utils.SuperTester

This method invokes all the getter methods.

testObjects(Object...) - Static method in class com.bluejeans.common.utils.SuperTester

Blindly tests all the objects.

testPublics() - Method in class com.bluejeans.common.utils.SuperTester

This method invokes all the available public methods.

testSetters() - Method in class com.bluejeans.common.utils.SuperTester

This method invokes all the setter methods.

TheonClient<E> - Class in com.bluejeans.common.utils.theon

Theon client to post using bulk operations

TheonClient() - Constructor for class com.bluejeans.common.utils.theon.TheonClient

The default one

TheonClient(String, String, String) - Constructor for class com.bluejeans.common.utils.theon.TheonClient

With url and credentials

TheonClient.TheonMessage<E> - Class in com.bluejeans.common.utils.theon

Encapsulates a theon message with topic and key

TheonClient.TheonStatus - Enum in com.bluejeans.common.utils.theon

Theon event enum

TheonMessage(String, E) - Constructor for class com.bluejeans.common.utils.theon.TheonClient.TheonMessage

Construct with topic and message, key will be empty string

TheonMessage(String, String, E) - Constructor for class com.bluejeans.common.utils.theon.TheonClient.TheonMessage

Construct with topic, key and message

toSize(String, String) - Method in class com.bluejeans.common.utils.URIInvoker

Gives the string representation of the size of the object represented by the property over the target.

U

update() - Method in class com.bluejeans.common.utils.kafka.SimpleKafkaConsumer

URIInvoker - Class in com.bluejeans.common.utils

Invoker based on URI strings.

URIInvoker(Object) - Constructor for class com.bluejeans.common.utils.URIInvoker

URIInvoker(Object...) - Constructor for class com.bluejeans.common.utils.URIInvoker

URIInvoker(Map<String, Object>) - Constructor for class com.bluejeans.common.utils.URIInvoker

V

VALUE_PREFIX - Static variable in class com.bluejeans.common.utils.InvokerService.InvokerServerHttpHandler

The values uri prefix.

valueOf(String) - Static method in enum com.bluejeans.common.utils.kafka.SimpleKafkaConsumer.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.bluejeans.common.utils.theon.TheonClient.TheonStatus

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.bluejeans.common.utils.kafka.SimpleKafkaConsumer.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.bluejeans.common.utils.theon.TheonClient.TheonStatus

Returns an array containing the constants of this enum type, in the order they are declared.

W

write(char[], int, int) - Method in class com.bluejeans.common.utils.InvokerService.InvokerInfoBuffer

writeLine(String, String) - Method in class com.bluejeans.common.utils.SystemInfo

Writes a line to the command stream.

writeLine(Process, String) - Method in class com.bluejeans.common.utils.SystemInfo

Writes a line to the command stream.

A B C D E F G H I K L M N O P R S T U V W