MCPcopy Create free account

hub / github.com/Advanced-SpringCloud/cloud-book / functions

Functions391 in github.com/Advanced-SpringCloud/cloud-book

↓ 17 callersMethodgetLogger
Getter method for property <tt>logger</tt>. @return property value of logger
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:143
↓ 14 callersMethodrun
()
chapter6-hystrix/src/main/java/com/xuan/chapter6/hystrix/service/CustomHystrixCommand.java:29
↓ 12 callersMethodrun
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:112
↓ 11 callersMethodtoString
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBinderConfigurationProperties.java:314
↓ 8 callersMethodgetHeaders
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBinderConfigurationProperties.java:73
↓ 7 callersMethodgetName
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/provisioning/RocketExchangeQueueProvisioner.java:124
↓ 5 callersMethodgetInstanceByServiceId
(@PathVariable("serviceId") String serviceId)
chapter6-hystrix/src/main/java/com/xuan/chapter6/hystrix/client/api/InstanceClient.java:17
↓ 5 callersMethodgetMessage
Retrieve the message envelope. @return the message envelope.
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketDelivery.java:18
↓ 4 callersMethodgetSimpleName
()
chapter3-springboot/chapter3-log-filter-starter/src/main/java/com/xuan/chapter3/logfilter/starter/config/EnableLogFilterImportSelector.java:75
↓ 3 callersMethodgetNameSrvConnectionString
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBinderConfigurationProperties.java:65
↓ 3 callersMethodisAutoCreateTopics
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBinderConfigurationProperties.java:226
↓ 3 callersMethodisEnableDlq
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketConsumerProperties.java:45
↓ 3 callersMethodsend
(Message message)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:166
↓ 3 callersMethodtoArray
(ByteBuffer buffer)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/utils/CommonUtils.java:8
↓ 2 callersMethodaccessTokenConverter
()
chapter12-cloud-security/chapter12-authorization-server/src/main/java/com/xuan/chapter12/authorization/server/config/AuthorizationServerConfig.java:55
↓ 2 callersMethodcreateTopicsIfAutoCreateEnabledAndAdminUtilsPresent
(final String topicName, final int partitionCount,
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/provisioning/RocketExchangeQueueProvisioner.java:95
↓ 2 callersMethodfilter
(ServerWebExchange exchange, GatewayFilterChain chain)
chapter8-gateway/chapter8-gateway-server/src/main/java/com/blueskykong/gateway/server/config/RateLimitByIpGatewayFilter.java:46
↓ 2 callersMethodgetAutoCommitOnError
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketConsumerProperties.java:53
↓ 2 callersMethodgetConfigurationProperties
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketMQResourceManager.java:18
↓ 2 callersMethodgetConsumer
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBindingProperties.java:9
↓ 2 callersMethodgetDlqName
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketConsumerProperties.java:100
↓ 2 callersMethodgetGroupName
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketCommonProperties.java:16
↓ 2 callersMethodgetId
()
chapter10-stream/rocket-demo/src/main/java/com/remcarpediem/rocket/rocketdemo/Order.java:19
↓ 2 callersMethodgetProducer
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBindingProperties.java:17
↓ 2 callersMethodgetServiceId
()
chapter-common/src/main/java/com/xuan/chapter/common/chapter5/dto/Instance.java:27
↓ 2 callersMethodgetTags
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketCommonProperties.java:8
↓ 2 callersMethodisActive
(RocketBlockingQueueConsumer consumer)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:170
↓ 2 callersMethodsetContent
(String content)
chapter7-ribbon/common/src/main/java/com/remcarpediem/ribbon/common/Order.java:19
↓ 2 callersMethodsetId
(Long id)
chapter7-ribbon/common/src/main/java/com/remcarpediem/ribbon/common/Order.java:11
↓ 2 callersMethodsetMessageBuilderFactory
(MessageBuilderFactory messageBuilderFactory)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:76
↓ 2 callersMethodtoConnectionString
Converts an array of host values to a comma-separated String. It will append the default port value, if not already specified.
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketMQBinderConfigurationProperties.java:158
↓ 2 callersMethodtokenServices
()
chapter12-cloud-security/chapter12-resource-server/src/main/java/com/xuan/chapter12/resource/server/config/ResourceServerConfig.java:48
↓ 2 callersMethodvalidateTopicName
Allowed chars are ASCII alphanumerics, '.', '_' and '-'.
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/utils/RocketMQTopicUtils.java:33
↓ 1 callersMethodaccessTokenConverter
()
chapter12-cloud-security/chapter12-resource-server/src/main/java/com/xuan/chapter12/resource/server/config/ResourceServerConfig.java:78
↓ 1 callersMethodbuildRabbitTemplate
(final ProducerDestination destination, ExtendedProducerProperties<RocketProducerProperties> producerPropertie
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/RocketMessageChannelBinder.java:116
↓ 1 callersMethodcancelled
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:110
↓ 1 callersMethodconvertToRocketMsg
(String destination, Message<?> message)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/AmqpOutboundEndpoint.java:158
↓ 1 callersMethodcreateAndSend
(Message message)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketInboundChannelAdapter.java:82
↓ 1 callersMethodcreateInstance
(@RequestBody Instance instance)
chapter5-openFeign/chapter5-feign-client/src/main/java/com/xuan/chapter5/feign/client/client/api/FeignServiceClient.java:22
↓ 1 callersMethodcreateNewBucket
()
chapter8-gateway/chapter8-gateway-server/src/main/java/com/blueskykong/gateway/server/config/RateLimitByIpGatewayFilter.java:40
↓ 1 callersMethoddeleteInstanceByServiceId
(@PathVariable("serviceId") String serviceId)
chapter5-openFeign/chapter5-feign-client/src/main/java/com/xuan/chapter5/feign/client/client/api/FeignServiceClient.java:19
↓ 1 callersMethoddoReceiveAndExecute
(RocketBlockingQueueConsumer consumer)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:135
↓ 1 callersMethoddoStart
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:74
↓ 1 callersMethodexecuteListener
(Message message)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:162
↓ 1 callersMethodfilter
(ServerWebExchange exchange, GatewayFilterChain chain)
chapter8-gateway/chapter8-gateway-server/src/main/java/com/blueskykong/gateway/server/ThrottleGatewayFilterFactory.java:50
↓ 1 callersMethodfromA
()
chapter13-sleuth/chapter13-client-serviceb/src/main/java/com/blueskykong/client/serviceb/feign/ServiceAClient.java:14
↓ 1 callersMethodfromB
()
chapter13-sleuth/chapter13-client-servicea/src/main/java/com/blueskykong/client/servicea/feign/ServiceBClient.java:14
↓ 1 callersMethodgetContent
()
chapter7-ribbon/common/src/main/java/com/remcarpediem/ribbon/common/Order.java:15
↓ 1 callersMethodgetContent
()
chapter10-stream/rocket-demo/src/main/java/com/remcarpediem/rocket/rocketdemo/Order.java:27
↓ 1 callersMethodgetId
()
chapter7-ribbon/common/src/main/java/com/remcarpediem/ribbon/common/Order.java:7
↓ 1 callersMethodgetInstanceByServiceId
(@PathVariable("serviceId") String serviceId)
chapter5-openFeign/chapter5-feign-client/src/main/java/com/xuan/chapter5/feign/client/client/api/FeignServiceClient.java:16
↓ 1 callersMethodgetName
()
chapter12-cloud-security/chapter12-resource-server/src/main/java/com/xuan/chapter12/resource/server/dto/User.java:29
↓ 1 callersMethodgetProducerProperties
Getter method for property <tt>producerProperties</tt>. @return property value of producerProperties
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:107
↓ 1 callersMethodgetResourceManager
Getter method for property <tt>resourceManager</tt>. @return property value of resourceManager
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:98
↓ 1 callersMethodgetStackTraceAsString
(Throwable cause)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/RocketMessageChannelBinder.java:245
↓ 1 callersMethodgetTopics
Getter method for property <tt>topics</tt>. @return property value of topics
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:134
↓ 1 callersMethodhandle
(RocketDelivery delivery)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:122
↓ 1 callersMethodhasDefaultFactory
()
chapter3-springboot/chapter3-log-filter-starter/src/main/java/com/xuan/chapter3/logfilter/starter/config/EnableLogFilterImportSelector.java:65
↓ 1 callersMethodhasDelivery
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:106
↓ 1 callersMethodheadersToMap
(RocketMQBinderConfigurationProperties configurationProperties)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/RocketMessageChannelBinder.java:72
↓ 1 callersMethodinitializeConsumers
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:88
↓ 1 callersMethodisAutoCommitOffset
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketConsumerProperties.java:29
↓ 1 callersMethodisAutoRebalanceEnabled
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/properties/RocketConsumerProperties.java:69
↓ 1 callersMethodisEnabled
()
chapter3-springboot/chapter3-log-filter-starter/src/main/java/com/xuan/chapter3/logfilter/starter/config/EnableLogFilterImportSelector.java:69
↓ 1 callersMethodnextMessage
(long timeout)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:114
↓ 1 callersMethodonMessage
(Message message)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/Listener.java:6
↓ 1 callersMethodoutput
()
chapter10-stream/demo/src/main/java/com/zt/stream/MsgSource.java:12
↓ 1 callersMethodprovisioningProvider
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/config/RocketMessageChannelBinderConfiguration.java:28
↓ 1 callersMethodrestTemplate
()
chapter12-cloud-security/chapter12-resource-server/src/main/java/com/xuan/chapter12/resource/server/config/ResourceServerConfig.java:85
↓ 1 callersMethodsendRocketMQ
(org.apache.rocketmq.common.message.Message message)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:156
↓ 1 callersMethodsetConsumerGroup
(String consumerGroup)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:208
↓ 1 callersMethodsetConsumerGroup
(String consumerGroup)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:64
↓ 1 callersMethodsetExtendedConsumerProperties
(ExtendedConsumerProperties<RocketConsumerProperties> extendedConsumerProperties)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:212
↓ 1 callersMethodsetExtendedConsumerProperties
(ExtendedConsumerProperties<RocketConsumerProperties> extendedConsumerProperties)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:68
↓ 1 callersMethodsetName
(String name)
chapter12-cloud-security/chapter12-resource-server/src/main/java/com/xuan/chapter12/resource/server/dto/User.java:33
↓ 1 callersMethodsetResourceManager
(RocketMQResourceManager resourceManager)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:199
↓ 1 callersMethodsetResourceManager
(RocketMQResourceManager resourceManager)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:56
↓ 1 callersMethodsetTopic
(String topic)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:203
↓ 1 callersMethodsetTopic
(String topic)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:60
↓ 1 callersMethodstart
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketTemplate.java:55
↓ 1 callersMethodstart
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:49
↓ 1 callersMethodtoDisplayString
(String original, int maxCharacters)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/RocketMessageChannelBinder.java:238
↓ 1 callersMethodupdateInstanceByServiceId
(@RequestBody Instance instance, @PathVariable("serviceId") String serviceId)
chapter5-openFeign/chapter5-feign-client/src/main/java/com/xuan/chapter5/feign/client/client/api/FeignServiceClient.java:25
MethodAmqpOutboundEndpoint
(RocketTemplate template)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/AmqpOutboundEndpoint.java:57
MethodAsyncMessageProcessingConsumer
(RocketBlockingQueueConsumer consumer)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/SimpleRocketMessageListenerContainer.java:107
MethodCustomCollapseCommand
(String serviceId)
chapter6-hystrix/src/main/java/com/xuan/chapter6/hystrix/service/CustomCollapseCommand.java:26
MethodCustomHystrixCommand
(RestTemplate restTemplate, String serviceId)
chapter6-hystrix/src/main/java/com/xuan/chapter6/hystrix/service/CustomHystrixCommand.java:21
MethodCustomHystrixObservableCommand
(RestTemplate restTemplate, String serviceId)
chapter6-hystrix/src/main/java/com/xuan/chapter6/hystrix/service/CustomHystrixObservableCommand.java:22
MethodCustomRemoteApplicationEvent
()
chapter11-bus/chapter11-config-server/src/main/java/com/blueskykong/chapter11/config/server/bus/CustomRemoteApplicationEvent.java:7
MethodFoo
()
chapter8-gateway/chapter8-gateway-server/src/main/java/com/blueskykong/gateway/server/GatewayServerApplication.java:58
MethodHello
()
chapter8-gateway/chapter8-gateway-server/src/main/java/com/blueskykong/gateway/server/config/RouteConfiguration.java:132
MethodInnerConsumer
()
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:134
MethodInstance
()
chapter-common/src/main/java/com/xuan/chapter/common/chapter5/dto/Instance.java:16
MethodInstanceBatchCommand
(List<String> serviceIds)
chapter6-hystrix/src/main/java/com/xuan/chapter6/hystrix/service/CustomCollapseCommand.java:63
MethodLogFilterRegistrationBean
()
chapter3-springboot/chapter3-log-filter-starter/src/main/java/com/xuan/chapter3/logfilter/starter/config/LogFilterRegistrationBean.java:11
MethodOrder
(Long id, String content)
chapter10-stream/rocket-demo/src/main/java/com/remcarpediem/rocket/rocketdemo/Order.java:7
MethodRocketBlockingQueueConsumer
(int prefetchCount)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketBlockingQueueConsumer.java:85
MethodRocketDelivery
(Message messageExt)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketDelivery.java:10
MethodRocketExchangeQueueProvisioner
(RocketMQBinderConfigurationProperties binderConfigurationProperties)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket-core/src/main/java/org/springframework/cloud/stream/binder/rocket/provisioning/RocketExchangeQueueProvisioner.java:31
MethodRocketInboundChannelAdapter
(SimpleRocketMessageListenerContainer container)
chapter10-stream/rocket-binder/spring-cloud-stream-binder-rocket/src/main/java/org/springframework/cloud/stream/binder/rocket/support/RocketInboundChannelAdapter.java:46
next →1–100 of 391, ranked by callers