View atributo nome
ResponseEntity<Map> response = restTemplate.exchange(userInfoEndpointUri, HttpMethod.GET, entity, Map.class); | |
Map userAttributes = response.getBody(); | |
model.addAttribute("name", userAttributes.get("name")); |
View oauth_login
<div class="col-sm-3 well"> | |
<h3>Logar com:</h3> | |
<div class="list-group"> | |
<p th:each="url : ${urls}"> | |
<a th:text="${url.key}" th:href="${url.value}" class="list-group-item active">Client</a> | |
</p> | |
</div> | |
</div> |
View application.properties oauth2
spring.security.oauth2.client.registration.google.client-id=368238083842-3d4gc7p54rs6bponn0qhn4nmf6apf24a.apps.googleusercontent.com | |
spring.security.oauth2.client.registration.google.client-secret=2RM2QkEaf3A8-iCNqSfdG8wP | |
spring.security.oauth2.client.registration.facebook.client-id=151640435578187 | |
spring.security.oauth2.client.registration.facebook.client-secret=3724fb293d401245b1ce7b2d70e97571 |
View maven oauth 2
<dependency> | |
<groupId>org.springframework.security</groupId> | |
<artifactId>spring-security-oauth2-client</artifactId> | |
</dependency> | |
<dependency> | |
<groupId>org.springframework.security</groupId> | |
<artifactId>spring-security-oauth2-jose</artifactId> | |
</dependency> |
View MessageListener
package com.boilerplate.kafka.service; | |
import java.util.concurrent.CountDownLatch; | |
import org.springframework.kafka.annotation.KafkaListener; | |
import org.springframework.kafka.support.KafkaHeaders; | |
import org.springframework.messaging.handler.annotation.Header; | |
import org.springframework.messaging.handler.annotation.Payload; | |
import com.boilerplate.kafka.model.Message; |
View messageProducer
package com.boilerplate.kafka.service; | |
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.beans.factory.annotation.Value; | |
import org.springframework.kafka.core.KafkaTemplate; | |
import org.springframework.kafka.support.SendResult; | |
import org.springframework.util.concurrent.ListenableFuture; | |
import org.springframework.util.concurrent.ListenableFutureCallback; | |
import com.boilerplate.kafka.model.Message; |
View kafkaAdmin
package com.boilerplate.kafka.config; | |
import java.util.HashMap; | |
import java.util.Map; | |
import org.apache.kafka.clients.admin.AdminClientConfig; | |
import org.apache.kafka.clients.admin.NewTopic; | |
import org.springframework.beans.factory.annotation.Value; | |
import org.springframework.context.annotation.Bean; | |
import org.springframework.context.annotation.Configuration; | |
import org.springframework.kafka.core.KafkaAdmin; |
View ktor
package com.ktor | |
import io.ktor.application.* | |
import io.ktor.http.* | |
import io.ktor.response.* | |
import io.ktor.routing.* | |
import io.ktor.server.engine.* | |
import io.ktor.server.netty.* | |
fun main(args: Array<String>) { | |
val server = embeddedServer(Netty, port = 8080) { |
View Controller Consul
package com.discovery.controller; | |
import java.net.URI; | |
import java.util.Optional; | |
import javax.naming.ServiceUnavailableException; | |
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.cloud.client.discovery.DiscoveryClient; | |
import org.springframework.http.HttpStatus; |
View bootstrap.yml
spring: | |
application: | |
name: consulApp | |
cloud: | |
consul: | |
host: localhost | |
port: 8500 | |
discovery: | |
healthCheckPath: /health-check | |
healthCheckInterval: 20s |
NewerOlder