MCPcopy Create free account

hub / github.com/Nepxion/EventBus / functions

Functions108 in github.com/Nepxion/EventBus

↓ 7 callersMethodtoString
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:98
↓ 6 callersMethodpost
(Object event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:19
↓ 4 callersMethodequals
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:93
↓ 3 callersMethodgetAsyncController
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:31
↓ 3 callersMethodgetController
(String identifier, boolean async)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:47
↓ 3 callersMethodgetSyncController
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:39
↓ 2 callersMethodcreateBlockingQueue
(String queue, int queueCapacity)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:157
↓ 2 callersMethodcreateRejectedPolicy
(String rejectedPolicy)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:172
↓ 2 callersMethodcreateThreadPoolExecutor
(String threadPoolName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:99
↓ 2 callersMethodcreateThreadPoolName
(String threadPoolName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:93
↓ 2 callersMethodfirstLetterToUpper
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/StringUtil.java:13
↓ 2 callersMethodgetLocalHost
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:129
↓ 2 callersMethodgetThreadPoolCorePoolSize
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:32
↓ 2 callersMethodgetThreadPoolKeepAliveTime
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:48
↓ 2 callersMethodgetThreadPoolMaximumPoolSize
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:40
↓ 2 callersMethodgetThreadPoolQueue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:64
↓ 2 callersMethodgetThreadPoolQueueCapacity
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:72
↓ 2 callersMethodgetThreadPoolRejectedPolicy
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:80
↓ 2 callersMethodgetValue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadQueueType.java:23
↓ 2 callersMethodisInvalidLocalHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:107
↓ 2 callersMethodisThreadPoolAllowCoreThreadTimeout
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:56
↓ 2 callersMethodisValidAddress
(String address)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:95
↓ 2 callersMethodpost
(Object event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:33
↓ 2 callersMethodpostEvent
(Event event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:23
↓ 2 callersMethodregister
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:15
↓ 1 callersMethodcreateAsyncController
(String identifier, Executor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:92
↓ 1 callersMethodcreateSharedThreadPoolExecutor
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:75
↓ 1 callersMethodcreateSyncController
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerFactory.java:80
↓ 1 callersMethodfromString
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadRejectedPolicyType.java:29
↓ 1 callersMethodfromString
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadQueueType.java:27
↓ 1 callersMethodgetLocalAddress
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 callersMethodgetLocalAddress0
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:150
↓ 1 callersMethodgetRandomPort
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:44
↓ 1 callersMethodgetThreadPoolExecutor
(String threadPoolName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:55
↓ 1 callersMethodgetThreadPoolSharedName
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:37
↓ 1 callersMethodgetValue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventType.java:22
↓ 1 callersMethodgetValue
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadRejectedPolicyType.java:25
↓ 1 callersMethodisThreadPoolMultiMode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:29
↓ 1 callersMethodisThreadPoolNameCustomized
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:45
↓ 1 callersMethodisThreadPoolNameIPShown
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:53
↓ 1 callersMethodpublish
()
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/service/MyPublisher.java:27
↓ 1 callersMethodrejected
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/RejectedRunnable.java:14
↓ 1 callersMethodsetThreadPoolAllowCoreThreadTimeout
(boolean threadPoolAllowCoreThreadTimeout)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:60
↓ 1 callersMethodsetThreadPoolCorePoolSize
(int threadPoolCorePoolSize)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:36
↓ 1 callersMethodsetThreadPoolKeepAliveTime
(long threadPoolKeepAliveTime)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:52
↓ 1 callersMethodsetThreadPoolMaximumPoolSize
(int threadPoolMaximumPoolSize)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:44
↓ 1 callersMethodsetThreadPoolMultiMode
(boolean threadPoolMultiMode)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:33
↓ 1 callersMethodsetThreadPoolNameCustomized
(boolean threadPoolNameCustomized)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:49
↓ 1 callersMethodsetThreadPoolNameIPShown
(boolean threadPoolNameIPShown)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:57
↓ 1 callersMethodsetThreadPoolQueue
(String threadPoolQueue)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:68
↓ 1 callersMethodsetThreadPoolQueueCapacity
(int threadPoolQueueCapacity)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:76
↓ 1 callersMethodsetThreadPoolRejectedPolicy
(String threadPoolRejectedPolicy)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:84
↓ 1 callersMethodsetThreadPoolSharedName
(String threadPoolSharedName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:41
↓ 1 callersMethodshutdown
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:191
↓ 1 callersMethodunregister
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventController.java:17
MethodAbortPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/AbortPolicyWithReport.java:23
MethodBlockingPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/BlockingPolicyWithReport.java:24
MethodCallerRunsPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/CallerRunsPolicyWithReport.java:23
MethodDiscardedPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/DiscardedPolicyWithReport.java:25
MethodEvent
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:24
MethodEventControllerImpl
(EventBus eventBus)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:19
MethodEventType
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventType.java:18
MethodRejectedPolicyWithReport
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/RejectedPolicyWithReport.java:25
MethodThreadPoolFactory
(ThreadCustomization threadCustomization, ThreadParameter threadParameter)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:50
MethodThreadQueueType
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadQueueType.java:19
MethodThreadRejectedPolicyType
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadRejectedPolicyType.java:21
Methodequals
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:41
Methodequals
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:66
MethodeventBeanPostProcessor
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:109
MethodeventContextClosedHandler
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:114
MethodeventControllerFactory
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:104
MethodfirstLetterToLower
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/StringUtil.java:19
MethodfromString
(String value)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventType.java:26
MethodgetAvailablePort
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:48
MethodgetIpByHost
(String hostName)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:191
MethodgetLocalSocketAddress
(String host, int port)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:115
MethodgetSource
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:32
MethodhashCode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/core/Event.java:36
MethodhashCode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadCustomization.java:61
MethodhashCode
()
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/entity/ThreadParameter.java:88
MethodisAnyHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:103
MethodisEnabled
()
eventbus-aop-starter/src/main/java/com/nepxion/eventbus/aop/EventBusImportSelector.java:22
MethodisInvalidPort
(int port)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:91
MethodisLocalHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:99
MethodisValidLocalHost
(String host)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/util/NetUtil.java:111
Methodmain
(String[] args)
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/MyApplication.java:22
MethodnewThread
(Runnable runnable)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/ThreadPoolFactory.java:124
MethodonApplicationEvent
(ContextClosedEvent event)
eventbus-aop/src/main/java/com/nepxion/eventbus/context/EventContextClosedHandler.java:34
MethodpostEvent
(Event event)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:45
MethodpostProcessAfterInitialization
(Object bean, String beanName)
eventbus-aop/src/main/java/com/nepxion/eventbus/aop/EventBeanPostProcessor.java:28
MethodpostProcessBeforeInitialization
(Object bean, String beanName)
eventbus-aop/src/main/java/com/nepxion/eventbus/aop/EventBeanPostProcessor.java:23
Methodregister
(Object object)
eventbus-aop/src/main/java/com/nepxion/eventbus/core/EventControllerImpl.java:23
MethodrejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/DiscardedPolicyWithReport.java:33
MethodrejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/BlockingPolicyWithReport.java:41
MethodrejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/CallerRunsPolicyWithReport.java:31
MethodrejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/RejectedPolicyWithReport.java:33
MethodrejectedExecution
(Runnable runnable, ThreadPoolExecutor executor)
eventbus-aop/src/main/java/com/nepxion/eventbus/thread/policy/AbortPolicyWithReport.java:31
Methodsubscribe
(String event)
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/service/MySubscriber2.java:25
Methodsubscribe
(String event)
eventbus-spring-boot-example/src/main/java/com/nepxion/eventbus/example/service/MySubscriber1.java:25
MethodthreadPoolFactory
()
eventbus-aop/src/main/java/com/nepxion/eventbus/configuration/EventConfiguration.java:84
next →1–100 of 108, ranked by callers