8 changed files with 0 additions and 246 deletions
@ -1,43 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import javax.persistence.Entity; |
|
||||||
import javax.persistence.GeneratedValue; |
|
||||||
import javax.persistence.Id; |
|
||||||
|
|
||||||
@Entity |
|
||||||
public class Account { |
|
||||||
|
|
||||||
@Id |
|
||||||
@GeneratedValue |
|
||||||
private Long id; |
|
||||||
|
|
||||||
private String username; |
|
||||||
|
|
||||||
Account() { |
|
||||||
} |
|
||||||
|
|
||||||
public Account(String username) { |
|
||||||
this.username = username; |
|
||||||
} |
|
||||||
|
|
||||||
public String getUsername() { |
|
||||||
return this.username; |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,23 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import org.springframework.data.repository.CrudRepository; |
|
||||||
|
|
||||||
public interface AccountRepository extends CrudRepository<Account, Long> { |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,45 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import org.springframework.jms.core.JmsTemplate; |
|
||||||
import org.springframework.stereotype.Service; |
|
||||||
import org.springframework.transaction.annotation.Transactional; |
|
||||||
|
|
||||||
@Service |
|
||||||
@Transactional |
|
||||||
public class AccountService { |
|
||||||
|
|
||||||
private final JmsTemplate jmsTemplate; |
|
||||||
|
|
||||||
private final AccountRepository accountRepository; |
|
||||||
|
|
||||||
public AccountService(JmsTemplate jmsTemplate, AccountRepository accountRepository) { |
|
||||||
this.jmsTemplate = jmsTemplate; |
|
||||||
this.accountRepository = accountRepository; |
|
||||||
} |
|
||||||
|
|
||||||
public void createAccountAndNotify(String username) { |
|
||||||
this.jmsTemplate.convertAndSend("java:/jms/queue/bootdemo", username); |
|
||||||
Account entity = new Account(username); |
|
||||||
this.accountRepository.save(entity); |
|
||||||
if ("error".equals(username)) { |
|
||||||
throw new RuntimeException("Simulated error"); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,30 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import org.springframework.jms.annotation.JmsListener; |
|
||||||
import org.springframework.stereotype.Component; |
|
||||||
|
|
||||||
@Component |
|
||||||
public class Messages { |
|
||||||
|
|
||||||
@JmsListener(destination = "java:/jms/queue/bootdemo") |
|
||||||
public void onMessage(String content) { |
|
||||||
System.out.println("----> " + content); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,24 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication; |
|
||||||
|
|
||||||
@SpringBootApplication |
|
||||||
public class SampleJndiApplication { |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,29 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import org.springframework.boot.builder.SpringApplicationBuilder; |
|
||||||
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer; |
|
||||||
|
|
||||||
public class SampleJndiInitializer extends SpringBootServletInitializer { |
|
||||||
|
|
||||||
@Override |
|
||||||
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) { |
|
||||||
return application.sources(SampleJndiApplication.class); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,49 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2012-2019 the original author or authors. |
|
||||||
* |
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
* you may not use this file except in compliance with the License. |
|
||||||
* You may obtain a copy of the License at |
|
||||||
* |
|
||||||
* https://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
* |
|
||||||
* Unless required by applicable law or agreed to in writing, software |
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
* See the License for the specific language governing permissions and |
|
||||||
* limitations under the License. |
|
||||||
*/ |
|
||||||
|
|
||||||
package smoketest.jndi; |
|
||||||
|
|
||||||
import org.springframework.web.bind.annotation.GetMapping; |
|
||||||
import org.springframework.web.bind.annotation.RestController; |
|
||||||
|
|
||||||
@RestController |
|
||||||
public class WebController { |
|
||||||
|
|
||||||
private final AccountService service; |
|
||||||
|
|
||||||
private final AccountRepository repository; |
|
||||||
|
|
||||||
public WebController(AccountService service, AccountRepository repository) { |
|
||||||
this.service = service; |
|
||||||
this.repository = repository; |
|
||||||
} |
|
||||||
|
|
||||||
@GetMapping("/") |
|
||||||
public String hello() { |
|
||||||
System.out.println("Count is " + this.repository.count()); |
|
||||||
this.service.createAccountAndNotify("josh"); |
|
||||||
try { |
|
||||||
this.service.createAccountAndNotify("error"); |
|
||||||
} |
|
||||||
catch (Exception ex) { |
|
||||||
System.out.println(ex.getMessage()); |
|
||||||
} |
|
||||||
long count = this.repository.count(); |
|
||||||
System.out.println("Count is " + count); |
|
||||||
return "Count is " + count; |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
Loading…
Reference in new issue