Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Nepxion/EventBus
/ functions
Functions
108 in github.com/Nepxion/EventBus
⨍
Functions
108
◇
Types & classes
28
↓ 7 callers
Method
toString
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:98
↓ 6 callers
Method
post
(Object event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:19
↓ 4 callers
Method
equals
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:93
↓ 3 callers
Method
getAsyncController
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:31
↓ 3 callers
Method
getController
(String identifier, boolean async)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:47
↓ 3 callers
Method
getSyncController
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:39
↓ 2 callers
Method
createBlockingQueue
(String queue, int queueCapacity)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:157
↓ 2 callers
Method
createRejectedPolicy
(String rejectedPolicy)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:172
↓ 2 callers
Method
createThreadPoolExecutor
(String threadPoolName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:99
↓ 2 callers
Method
createThreadPoolName
(String threadPoolName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:93
↓ 2 callers
Method
firstLetterToUpper
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/StringUtil.java:13
↓ 2 callers
Method
getLocalHost
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:129
↓ 2 callers
Method
getThreadPoolCorePoolSize
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:32
↓ 2 callers
Method
getThreadPoolKeepAliveTime
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:48
↓ 2 callers
Method
getThreadPoolMaximumPoolSize
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:40
↓ 2 callers
Method
getThreadPoolQueue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:64
↓ 2 callers
Method
getThreadPoolQueueCapacity
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:72
↓ 2 callers
Method
getThreadPoolRejectedPolicy
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:80
↓ 2 callers
Method
getValue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadQueueType.java:23
↓ 2 callers
Method
isInvalidLocalHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:107
↓ 2 callers
Method
isThreadPoolAllowCoreThreadTimeout
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:56
↓ 2 callers
Method
isValidAddress
(String address)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:95
↓ 2 callers
Method
post
(Object event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:33
↓ 2 callers
Method
postEvent
(Event event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:23
↓ 2 callers
Method
register
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:15
↓ 1 callers
Method
createAsyncController
(String identifier, Executor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:92
↓ 1 callers
Method
createSharedThreadPoolExecutor
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:75
↓ 1 callers
Method
createSyncController
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:80
↓ 1 callers
Method
fromString
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadRejectedPolicyType.java:29
↓ 1 callers
Method
fromString
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadQueueType.java:27
↓ 1 callers
Method
getLocalAddress
Find first valid IP from local network card @return first valid local IP
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:139
↓ 1 callers
Method
getLocalAddress0
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:150
↓ 1 callers
Method
getRandomPort
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:44
↓ 1 callers
Method
getThreadPoolExecutor
(String threadPoolName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:55
↓ 1 callers
Method
getThreadPoolSharedName
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:37
↓ 1 callers
Method
getValue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventType.java:22
↓ 1 callers
Method
getValue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadRejectedPolicyType.java:25
↓ 1 callers
Method
isThreadPoolMultiMode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:29
↓ 1 callers
Method
isThreadPoolNameCustomized
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:45
↓ 1 callers
Method
isThreadPoolNameIPShown
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:53
↓ 1 callers
Method
publish
()
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/service/MyPublisher.java:27
↓ 1 callers
Method
rejected
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/RejectedRunnable.java:14
↓ 1 callers
Method
setThreadPoolAllowCoreThreadTimeout
(boolean threadPoolAllowCoreThreadTimeout)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:60
↓ 1 callers
Method
setThreadPoolCorePoolSize
(int threadPoolCorePoolSize)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:36
↓ 1 callers
Method
setThreadPoolKeepAliveTime
(long threadPoolKeepAliveTime)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:52
↓ 1 callers
Method
setThreadPoolMaximumPoolSize
(int threadPoolMaximumPoolSize)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:44
↓ 1 callers
Method
setThreadPoolMultiMode
(boolean threadPoolMultiMode)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:33
↓ 1 callers
Method
setThreadPoolNameCustomized
(boolean threadPoolNameCustomized)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:49
↓ 1 callers
Method
setThreadPoolNameIPShown
(boolean threadPoolNameIPShown)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:57
↓ 1 callers
Method
setThreadPoolQueue
(String threadPoolQueue)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:68
↓ 1 callers
Method
setThreadPoolQueueCapacity
(int threadPoolQueueCapacity)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:76
↓ 1 callers
Method
setThreadPoolRejectedPolicy
(String threadPoolRejectedPolicy)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:84
↓ 1 callers
Method
setThreadPoolSharedName
(String threadPoolSharedName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:41
↓ 1 callers
Method
shutdown
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:191
↓ 1 callers
Method
unregister
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:17
Method
AbortPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/AbortPolicyWithReport.java:23
Method
BlockingPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/BlockingPolicyWithReport.java:24
Method
CallerRunsPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/CallerRunsPolicyWithReport.java:23
Method
DiscardedPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/DiscardedPolicyWithReport.java:25
Method
Event
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:24
Method
EventControllerImpl
(EventBus eventBus)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:19
Method
EventType
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventType.java:18
Method
RejectedPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/RejectedPolicyWithReport.java:25
Method
ThreadPoolFactory
(ThreadCustomization threadCustomization, ThreadParameter threadParameter)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:50
Method
ThreadQueueType
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadQueueType.java:19
Method
ThreadRejectedPolicyType
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadRejectedPolicyType.java:21
Method
equals
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:41
Method
equals
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:66
Method
eventBeanPostProcessor
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:109
Method
eventContextClosedHandler
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:114
Method
eventControllerFactory
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:104
Method
firstLetterToLower
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/StringUtil.java:19
Method
fromString
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventType.java:26
Method
getAvailablePort
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:48
Method
getIpByHost
(String hostName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:191
Method
getLocalSocketAddress
(String host, int port)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:115
Method
getSource
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:32
Method
hashCode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:36
Method
hashCode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:61
Method
hashCode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:88
Method
isAnyHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:103
Method
isEnabled
()
eventbus-aop-starter/src/main/java/com/nepxion/eventbus/aop/EventBusImportSelector.java:22
Method
isInvalidPort
(int port)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:91
Method
isLocalHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:99
Method
isValidLocalHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:111
Method
main
(String[] args)
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/MyApplication.java:22
Method
newThread
(Runnable runnable)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:124
Method
onApplicationEvent
(ContextClosedEvent event)
eventbus-aop/src/main/java/com/nepxion/eventbus/context/EventContextClosedHandler.java:34
Method
postEvent
(Event event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:45
Method
postProcessAfterInitialization
(Object bean, String beanName)
eventbus-aop/src/main/java/com/nepxion/eventbus/aop/EventBeanPostProcessor.java:28
Method
postProcessBeforeInitialization
(Object bean, String beanName)
eventbus-aop/src/main/java/com/nepxion/eventbus/aop/EventBeanPostProcessor.java:23
Method
register
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:23
Method
rejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/DiscardedPolicyWithReport.java:33
Method
rejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/BlockingPolicyWithReport.java:41
Method
rejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/CallerRunsPolicyWithReport.java:31
Method
rejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/RejectedPolicyWithReport.java:33
Method
rejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/AbortPolicyWithReport.java:31
Method
subscribe
(String event)
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/service/MySubscriber2.java:25
Method
subscribe
(String event)
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/service/MySubscriber1.java:25
Method
threadPoolFactory
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:84
next →
1–100 of 108, ranked by callers