Index

B C D E G I L O P R S W
All Classes and Interfaces|All Packages

B

basicAck(long, boolean) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Acknowledge a message by its delivery tag See Channel.basicAck(long, boolean)

C

com.kamikazejam.kamicommon.amqp - package com.kamikazejam.kamicommon.amqp

com.kamikazejam.kamicommon.amqp.callback - package com.kamikazejam.kamicommon.amqp.callback

com.kamikazejam.kamicommon.amqp.data - package com.kamikazejam.kamicommon.amqp.data

com.kamikazejam.kamicommon.database - package com.kamikazejam.kamicommon.database

com.kamikazejam.kamicommon.redis - package com.kamikazejam.kamicommon.redis

com.kamikazejam.kamicommon.redis.callback - package com.kamikazejam.kamicommon.redis.callback

com.kamikazejam.kamicommon.redis.logger - package com.kamikazejam.kamicommon.redis.logger

com.kamikazejam.kamicommon.redis.util - package com.kamikazejam.kamicommon.redis.util

com.kamikazejam.kamicommon.util.interfaces - package com.kamikazejam.kamicommon.util.interfaces

com.kamikazejam.kamicommon.util.log - package com.kamikazejam.kamicommon.util.log

connect() - Method in interface com.kamikazejam.kamicommon.redis.util.RedisMonitor.RedisRetry

consume(String) - Method in interface com.kamikazejam.kamicommon.amqp.callback.RabbitRpcCallback

consume(String) - Method in interface com.kamikazejam.kamicommon.amqp.callback.RabbitServerCallback

createConsumer(Channel) - Method in class com.kamikazejam.kamicommon.amqp.data.RabbitStdConsumer

D

Database - Class in com.kamikazejam.kamicommon.database

Database(String, int, String, String, String) - Constructor for class com.kamikazejam.kamicommon.database.Database

DatabaseListener - Interface in com.kamikazejam.kamicommon.database

debug(String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

declareQueue(String) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Declares a queue with a default TTL of 60 seconds (iff not declared already)

declareQueue(String, boolean, boolean, boolean, Long) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Declares a queue with a specified TTL (iff not declared already)

declareQueue(String, Long) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Declares a queue with a specified TTL (iff not declared already)

DefaultRedisLogger - Class in com.kamikazejam.kamicommon.redis.logger

DefaultRedisLogger() - Constructor for class com.kamikazejam.kamicommon.redis.logger.DefaultRedisLogger

E

error(String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

error(Throwable) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

error(Throwable, String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

G

getAPI(RedisConf) - Static method in class com.kamikazejam.kamicommon.redis.RedisConnector

Get a RedisAPI instance for the given connection config.

getAPI(RedisConf, LoggerService) - Static method in class com.kamikazejam.kamicommon.redis.RedisConnector

Get a RedisAPI instance for the given connection config.

getAPI(String) - Static method in class com.kamikazejam.kamicommon.amqp.RabbitMQConnector

Get a RabbitMQAPI instance for the given connection URL.

getChannel() - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Get the underlying RabbitMQ Channel for direct access

getCmdsAsync() - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

getCmdsSync() - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

getConnection() - Method in class com.kamikazejam.kamicommon.database.Database

getConnection() - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

getLoggerName() - Method in class com.kamikazejam.kamicommon.redis.logger.DefaultRedisLogger

getLoggerName() - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

getRedis() - Method in interface com.kamikazejam.kamicommon.redis.util.RedisMonitor.RedisAccess

getState() - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

getURI() - Method in class com.kamikazejam.kamicommon.redis.util.RedisConf

I

info(String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

info(Throwable) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

info(Throwable, String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

info(String) - Method in class com.kamikazejam.kamicommon.database.Database

isConnected() - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

isDebug() - Method in class com.kamikazejam.kamicommon.redis.logger.DefaultRedisLogger

isDebug() - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

isRunning() - Method in class com.kamikazejam.kamicommon.redis.util.RedisMonitor

isRunning() - Method in interface com.kamikazejam.kamicommon.util.interfaces.Service

L

LoggerService - Class in com.kamikazejam.kamicommon.util.log

A simple logger service that provides an abstraction for where to log messages.

Override LoggerService.logToConsole(java.lang.String, java.util.logging.Level) to change how log messages are processed.

LoggerService() - Constructor for class com.kamikazejam.kamicommon.util.log.LoggerService

logToConsole(String, Level) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

O

of(String) - Static method in class com.kamikazejam.kamicommon.redis.util.RedisConf

Creates a RedisConfig object with the given address Defaults: port 6379, no authentication

of(String, int) - Static method in class com.kamikazejam.kamicommon.redis.util.RedisConf

Creates a RedisConfig object with the given address and port Defaults: no authentication

of(String, int, String) - Static method in class com.kamikazejam.kamicommon.redis.util.RedisConf

Creates a RedisConfig object with the given address, port, and password

onConnected() - Method in class com.kamikazejam.kamicommon.database.Database

onConnected() - Method in interface com.kamikazejam.kamicommon.database.DatabaseListener

onConnectionFailed() - Method in class com.kamikazejam.kamicommon.database.Database

onConnectionFailed() - Method in interface com.kamikazejam.kamicommon.database.DatabaseListener

onExceptionCaught(Exception) - Method in class com.kamikazejam.kamicommon.database.Database

onExceptionCaught(Exception) - Method in interface com.kamikazejam.kamicommon.database.DatabaseListener

onMessage(String, String) - Method in interface com.kamikazejam.kamicommon.redis.callback.RedisChannelCallback

P

publish(String, boolean) - Method in class com.kamikazejam.kamicommon.redis.RedisChannel

publish(String, String, boolean) - Method in class com.kamikazejam.kamicommon.redis.RedisMultiChannel

publishAsync(String) - Method in class com.kamikazejam.kamicommon.redis.RedisChannel

publishAsync(String, String) - Method in class com.kamikazejam.kamicommon.redis.RedisMultiChannel

publishFanout(String, String) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Publish a message to a queue - does NOT listen for a response

publishFanout(String, AMQP.BasicProperties, String) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Publish a message to a queue (with properties) - does NOT listen for a response

publishMessage(String, String) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Publish a message to a queue - does NOT listen for a response

publishMessage(String, AMQP.BasicProperties, String) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Publish a message to a queue (with properties) - does NOT listen for a response

publishRPC(RabbitRpcQueue, String) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Publish a 'RPC' style message and wait for a response

publishSync(String) - Method in class com.kamikazejam.kamicommon.redis.RedisChannel

publishSync(String, String) - Method in class com.kamikazejam.kamicommon.redis.RedisMultiChannel

R

RabbitMQAPI - Class in com.kamikazejam.kamicommon.amqp

RabbitMQConnector - Class in com.kamikazejam.kamicommon.amqp

The source for all RabbitMQ interactions.

RabbitMQConnector() - Constructor for class com.kamikazejam.kamicommon.amqp.RabbitMQConnector

RabbitRpcCallback - Interface in com.kamikazejam.kamicommon.amqp.callback

RabbitRpcConsumer - Class in com.kamikazejam.kamicommon.amqp.data

RabbitRpcConsumer(RabbitMQAPI, String, RabbitRpcCallback) - Constructor for class com.kamikazejam.kamicommon.amqp.data.RabbitRpcConsumer

RabbitRpcQueue - Class in com.kamikazejam.kamicommon.amqp.data

Represents a pair of client and server queues for RPC communication.

RabbitRpcQueue(String) - Constructor for class com.kamikazejam.kamicommon.amqp.data.RabbitRpcQueue

Creates a new pair of client and server queues based on the given queue stem.

RabbitServerCallback - Interface in com.kamikazejam.kamicommon.amqp.callback

RabbitStdConsumer - Class in com.kamikazejam.kamicommon.amqp.data

RabbitStdConsumer(String, RabbitServerCallback, boolean) - Constructor for class com.kamikazejam.kamicommon.amqp.data.RabbitStdConsumer

RedisAPI - Class in com.kamikazejam.kamicommon.redis

RedisChannel - Class in com.kamikazejam.kamicommon.redis

RedisChannelCallback - Interface in com.kamikazejam.kamicommon.redis.callback

RedisConf - Class in com.kamikazejam.kamicommon.redis.util

RedisConf(String, int, String) - Constructor for class com.kamikazejam.kamicommon.redis.util.RedisConf

Creates a RedisConfig object with the given address, port, and password

RedisConnector - Class in com.kamikazejam.kamicommon.redis

The source for all RabbitMQ interactions.

RedisConnector() - Constructor for class com.kamikazejam.kamicommon.redis.RedisConnector

RedisMonitor - Class in com.kamikazejam.kamicommon.redis.util

RedisMonitor(RedisState, LoggerService, RedisMonitor.RedisAccess, RedisMonitor.RedisRetry) - Constructor for class com.kamikazejam.kamicommon.redis.util.RedisMonitor

RedisMonitor.RedisAccess - Interface in com.kamikazejam.kamicommon.redis.util

RedisMonitor.RedisRetry - Interface in com.kamikazejam.kamicommon.redis.util

RedisMultiChannel - Class in com.kamikazejam.kamicommon.redis

RedisState - Class in com.kamikazejam.kamicommon.redis.util

RedisState() - Constructor for class com.kamikazejam.kamicommon.redis.util.RedisState

registerChannel(String) - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

registerFanConsumer(String, String, RabbitServerCallback) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Register a standard consumer (default to auto-acknowledgement)

registerFanConsumer(String, String, RabbitServerCallback, boolean) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Register a standard consumer

registerMultiChannel(String...) - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

registerRpcConsumer(RabbitRpcQueue, RabbitRpcCallback) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Register a 'RPC' style consumer to listen for requests

registerStdConsumer(String, RabbitServerCallback) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Register a standard consumer (default to auto-acknowledgement)

registerStdConsumer(String, RabbitServerCallback, boolean) - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Register a standard consumer

run() - Method in class com.kamikazejam.kamicommon.redis.util.RedisMonitor

S

Service - Interface in com.kamikazejam.kamicommon.util.interfaces

severe(String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

severe(Throwable) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

severe(Throwable, String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

shutdown() - Method in class com.kamikazejam.kamicommon.redis.RedisAPI

Stops the internal Redis Connection This API remains usable, but other methods may incur additional delays if the connection needs to be re-established

shutdown() - Method in class com.kamikazejam.kamicommon.redis.util.RedisMonitor

shutdown() - Method in interface com.kamikazejam.kamicommon.util.interfaces.Service

start() - Method in class com.kamikazejam.kamicommon.redis.util.RedisMonitor

start() - Method in interface com.kamikazejam.kamicommon.util.interfaces.Service

stop() - Method in class com.kamikazejam.kamicommon.amqp.RabbitMQAPI

Stops the internal RabbitMQ Connection and Channel This API remains usable, but other methods may incur additional delays as the connection is re-established

subscribe(RedisChannelCallback) - Method in class com.kamikazejam.kamicommon.redis.RedisChannel

Add a callback for this channel (for listening to messages)

subscribe(RedisChannelCallback) - Method in class com.kamikazejam.kamicommon.redis.RedisMultiChannel

Add a callback for this channel (for listening to messages)

W

warn(String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

warn(Throwable) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

warn(Throwable, String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

warn(String) - Method in class com.kamikazejam.kamicommon.database.Database

warning(String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

warning(Throwable) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

warning(Throwable, String) - Method in class com.kamikazejam.kamicommon.util.log.LoggerService

B C D E G I L O P R S W
All Classes and Interfaces|All Packages